Home
last modified time | relevance | path

Searched refs:requestMessagesFromDeframer (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java95 transportState().requestMessagesFromDeframer(numMessages); in request()
100 transportState().requestMessagesFromDeframer(numMessages); in request()
DNettyClientStream.java192 transportState().requestMessagesFromDeframer(numMessages); in request()
197 transportState().requestMessagesFromDeframer(numMessages); in request()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java326 stream.transportState().requestMessagesFromDeframer(1); in rstStreamClosesStream()
346 stream.transportState().requestMessagesFromDeframer(1); in trailerOkWithTruncatedMessage()
363 stream.transportState().requestMessagesFromDeframer(1); in trailerNotOkWithTruncatedMessage()
DAbstractServerStreamTest.java164 stream.transportState().requestMessagesFromDeframer(1); in partialMessageAtEndOfStreamShouldFail()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractStream.java203 public final void requestMessagesFromDeframer(final int numMessages) { in requestMessagesFromDeframer() method in AbstractStream.TransportState
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientStream.java171 state.requestMessagesFromDeframer(numMessages); in request()
/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetClientStream.java189 state.requestMessagesFromDeframer(numMessages); in request()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java316 streamTransportState.requestMessagesFromDeframer(1); in inboundShouldForwardToStream()