Home
last modified time | relevance | path

Searched refs:newSubstream (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DRetriableStreamTest.java160 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata metadata) { in newSubstream() method in RetriableStreamTest.RecordedRetriableStream
165 return retriableStreamRecorder.newSubstream(actualPreviousRpcAttemptsInHeader); in newSubstream()
196 doReturn(mockStream1).when(retriableStreamRecorder).newSubstream(0); in retry_everythingDrained()
217 inOrder.verify(retriableStreamRecorder).newSubstream(0); in retry_everythingDrained()
250 doReturn(mockStream2).when(retriableStreamRecorder).newSubstream(1); in retry_everythingDrained()
263 inOrder.verify(retriableStreamRecorder).newSubstream(1); in retry_everythingDrained()
294 doReturn(mockStream3).when(retriableStreamRecorder).newSubstream(2); in retry_everythingDrained()
310 inOrder.verify(retriableStreamRecorder).newSubstream(2); in retry_everythingDrained()
344 doReturn(mockStream1).when(retriableStreamRecorder).newSubstream(0); in headersRead_cancel()
365 doReturn(mockStream1).when(retriableStreamRecorder).newSubstream(0); in retry_headersRead_cancel()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DRetriableStream.java175 sub.stream = newSubstream(tracerFactory, newHeaders); in createSubstream()
183 abstract ClientStream newSubstream( in newSubstream() method in RetriableStream
575 Substream newSubstream = createSubstream( in closed()
577 drain(newSubstream); in closed()
606 Substream newSubstream = createSubstream(substream.previousAttempts + 1); in closed()
607 drain(newSubstream); in closed()
DManagedChannelImpl.java526 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata newHeaders) {