Searched refs:MessageFramer (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageFramerTest.java | 52 private MessageFramer.Sink sink;
55 private MessageFramer framer;
74 framer = new MessageFramer(sink, allocator, statsTraceCtx); in setUp()
139 framer = new MessageFramer(sink, allocator, statsTraceCtx); in payloadSplitBetweenSinks()
155 framer = new MessageFramer(sink, allocator, statsTraceCtx); in frameHeaderSplitBetweenSinks()
203 framer = new MessageFramer(sink, allocator, statsTraceCtx); in largerFrameSize()
224 framer = new MessageFramer(sink, allocator, statsTraceCtx); in largerFrameSizeUnknownLength()
252 framer = new MessageFramer(sink, allocator, statsTraceCtx) in compressed()
278 framer = new MessageFramer(sink, allocator, statsTraceCtx)
303 framer = new MessageFramer(sink, allocator, statsTraceCtx)
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerStream.java | 33 implements ServerStream, MessageFramer.Sink {
79 private final MessageFramer framer;
87 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractServerStream()
100 protected final MessageFramer framer() { in framer()
|
| D | MessageFramer.java | 42 public class MessageFramer implements Framer { class
95 public MessageFramer( in MessageFramer() method in MessageFramer
103 public MessageFramer setCompressor(Compressor compressor) { in setCompressor()
109 public MessageFramer setMessageCompression(boolean enable) { in setMessageCompression()
|
| D | AbstractClientStream.java | 48 implements ClientStream, MessageFramer.Sink {
117 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractClientStream()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 34 import io.grpc.internal.MessageFramer;
248 MessageFramer framer = new MessageFramer( in grpcDataFrame()
249 new MessageFramer.Sink() { in grpcDataFrame()
|