Searched refs:newSubstream (Results 1 – 3 of 3) sorted by relevance
160 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata metadata) { in newSubstream() method in RetriableStreamTest.RecordedRetriableStream165 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 …]
175 sub.stream = newSubstream(tracerFactory, newHeaders); in createSubstream()183 abstract ClientStream newSubstream( in newSubstream() method in RetriableStream575 Substream newSubstream = createSubstream( in closed()577 drain(newSubstream); in closed()606 Substream newSubstream = createSubstream(substream.previousAttempts + 1); in closed()607 drain(newSubstream); in closed()
493 ClientStream newSubstream(ClientStreamTracer.Factory tracerFactory, Metadata newHeaders) { in newRetriableStream() method in ManagedChannelImpl.ChannelTransportProvider.RetryStream