Searched refs:masterListener (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | RetriableStreamTest.java | 117 private final ClientStreamListener masterListener = mock(ClientStreamListener.class); field in RetriableStreamTest
198 inOrder(retriableStreamRecorder, masterListener, mockStream1, mockStream2, mockStream3); in retry_everythingDrained()
214 retriableStream.start(masterListener); in retry_everythingDrained()
337 inOrder.verify(masterListener).closed(any(Status.class), any(Metadata.class)); in retry_everythingDrained()
347 retriableStream.start(masterListener); in headersRead_cancel()
368 retriableStream.start(masterListener); in retry_headersRead_cancel()
403 retriableStream.start(masterListener); in headersRead_closed()
417 verify(masterListener).closed(status, metadata); in headersRead_closed()
427 retriableStream.start(masterListener); in retry_headersRead_closed()
454 verify(masterListener).closed(status, metadata); in retry_headersRead_closed()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | RetriableStream.java | 93 private ClientStreamListener masterListener; field in RetriableStream
260 masterListener = listener; in start()
298 masterListener.closed(reason, new Metadata()); in cancel()
539 masterListener.headersRead(headers); in headersRead()
562 masterListener.closed(status, trailers); in closed()
622 masterListener.closed(status, trailers); in closed()
688 masterListener.messagesAvailable(producer); in messagesAvailable()
695 masterListener.onReady(); in onReady()
|