| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | Http2ClientStreamTransportStateTest.java | 84 verify(mockListener).headersRead(headers); in transportHeadersReceived_notifiesListener()
98 verify(mockListener).headersRead(headers); in transportHeadersReceived_doesntRequire200()
111 verify(mockListener, never()).headersRead(any(Metadata.class)); in transportHeadersReceived_noHttpStatus()
126 verify(mockListener, never()).headersRead(any(Metadata.class)); in transportHeadersReceived_wrongContentType_200()
142 verify(mockListener, never()).headersRead(any(Metadata.class)); in transportHeadersReceived_wrongContentType_401()
168 verify(mockListener).headersRead(headers); in transportHeadersReceived_handles_1xx()
184 verify(mockListener).headersRead(headers); in transportHeadersReceived_twice()
204 verify(mockListener, never()).headersRead(any(Metadata.class)); in transportHeadersReceived_unknownAndTwiceLogsSecondHeaders()
247 verify(mockListener, never()).headersRead(any(Metadata.class)); in transportTrailersReceived_notifiesListener()
264 verify(mockListener).headersRead(headers); in transportTrailersReceived_afterHeaders()
[all …]
|
| D | ForwardingClientStreamListenerTest.java | 56 forward.headersRead(headers); in headersReadTest()
57 verify(mock).headersRead(same(headers)); in headersReadTest()
|
| D | DelayedStreamTest.java | 313 passedListener.headersRead(headers); in listener_allQueued()
323 inOrder.verify(listener).headersRead(headers); in listener_allQueued()
344 delayedListener.headersRead(headers); in listener_noQueued()
345 verify(listener).headersRead(headers); in listener_noQueued()
|
| D | AbstractClientStreamTest.java | 189 verify(mockListener).headersRead(headers); in inboundHeadersReceived_notifiesListener()
216 verify(mockListener).headersRead(headers); in inboundHeadersReceived_acceptsGzipContentEncoding()
231 verify(mockListener).headersRead(headers); in inboundHeadersReceived_contentEncodingIsCaseInsensitive()
286 verify(mockListener).headersRead(headers); in inboundHeadersReceived_acceptsGzipMessageEncoding()
298 verify(mockListener).headersRead(headers); in inboundHeadersReceived_acceptsIdentityMessageEncoding()
|
| D | NoopClientStreamListener.java | 33 public void headersRead(Metadata headers) {} in headersRead() method in NoopClientStreamListener
|
| D | ClientCallImplTest.java | 157 streamListener.headersRead(new Metadata()); in statusPropagatedFromStreamToCallListener()
179 streamListener.headersRead(new Metadata()); in exceptionInOnMessageTakesPrecedenceOverServer()
226 streamListener.headersRead(new Metadata()); in exceptionInOnHeadersTakesPrecedenceOverServer()
564 listener.headersRead(new Metadata()); in callerContextPropagatedToListener()
903 streamListener.headersRead(new Metadata()); in cancelInOnMessageShouldInvokeStreamCancel()
|
| D | RetriableStreamTest.java | 353 sublistenerCaptor1.getValue().headersRead(new Metadata()); in headersRead_cancel()
387 sublistenerCaptor2.getValue().headersRead(new Metadata()); in retry_headersRead_cancel()
409 sublistenerCaptor1.getValue().headersRead(new Metadata()); in headersRead_closed()
445 sublistenerCaptor2.getValue().headersRead(new Metadata()); in retry_headersRead_closed()
648 sublistenerCaptor2.get().headersRead(new Metadata()); in operationsWhileDraining()
722 sublistenerCaptor1.getValue().headersRead(new Metadata()); in operationsAfterImmediateCommit()
818 listener.headersRead(new Metadata()); in messageAvailable()
1379 sublistenerCaptor.getValue().headersRead(new Metadata()); in throttleStream_Succeed()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingClientStreamListener.java | 28 public void headersRead(Metadata headers) { in headersRead() method in ForwardingClientStreamListener
29 delegate().headersRead(headers); in headersRead()
|
| D | ClientStreamListener.java | 34 void headersRead(Metadata headers); in headersRead() method
|
| D | DelayedStream.java | 415 public void headersRead(final Metadata headers) { in headersRead() method in DelayedStream.DelayedStreamListener
419 realListener.headersRead(headers); in headersRead()
|
| D | RetriableStream.java | 536 public void headersRead(Metadata headers) { in headersRead() method in RetriableStream.Sublistener
539 masterListener.headersRead(headers); in headersRead()
|
| D | AbstractClientStream.java | 338 listener().headersRead(headers); in inboundHeadersReceived()
|
| D | ClientCallImpl.java | 476 public void headersRead(final Metadata headers) { in headersRead() method in ClientCallImpl.ClientStreamListenerImpl
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 413 clientStreamListener.headersRead(headers);
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientStreamTest.java | 250 verify(listener).headersRead(any(Metadata.class)); in inboundHeadersShouldCallListenerHeadersRead()
|
| D | NettyClientHandlerTest.java | 312 verify(streamListener).headersRead(captor.capture()); in inboundShouldForwardToStream()
|
| D | NettyClientTransportTest.java | 685 public void headersRead(Metadata headers) { in headersRead() method in NettyClientTransportTest.TestClientStreamListener
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 282 verify(mockClientStreamListener2, timeout(250)).headersRead(any(Metadata.class)); in frameAfterRstStreamShouldNotBreakClientChannel()
1085 public void headersRead(Metadata headers) { in clientCancelFromWithinMessageRead()
1996 public void headersRead(Metadata headers) { in headersRead() method in AbstractTransportTest.ClientStreamListenerBase
|
| /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
| D | CronetClientStreamTest.java | 245 verify(clientListener).headersRead(metadataCaptor.capture()); in read()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 1948 public void headersRead(Metadata headers) { in headersRead() method in OkHttpClientTransportTest.MockStreamListener
|