ThreadOptimizedDeframer

All Superinterfaces:: Deframer

public interface ThreadOptimizedDeframer extends Deframer

A Deframer that optimizations by taking over part of the thread safety.

Method Summary

Modifier and Type

Method

Description

void

request(int numMessages)

Behaves like Deframer.request(int) except it can be called from any thread.

Methods inherited from interface io.grpc.internal.Deframer
close, closeWhenComplete, deframe, setDecompressor, setFullStreamDecompressor, setMaxInboundMessageSize

Method Details
- request
  
  void request(int numMessages)
  
  Behaves like Deframer.request(int) except it can be called from any thread. Must not throw exceptions in case of deframer error.
  
  Specified by:
  
  request in interface Deframer
  
  Parameters:
  
  numMessages - the requested number of messages to be delivered to the listener.