HomeSort by relevance Sort by last modified time
    Searched refs:headersRead (Results 1 - 21 of 21) sorted by null

  /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
ClientStreamListener.java 34 void headersRead(Metadata headers);
ForwardingClientStreamListener.java 28 public void headersRead(Metadata headers) {
29 delegate().headersRead(headers);
DelayedStream.java 415 public void headersRead(final Metadata headers) {
419 realListener.headersRead(headers);
AbstractClientStream.java 338 listener().headersRead(headers);
RetriableStream.java 536 public void headersRead(Metadata headers) {
539 masterListener.headersRead(headers);
ClientCallImpl.java 476 public void headersRead(final Metadata headers) {
477 class HeadersRead extends ContextRunnable {
478 HeadersRead() {
498 callExecutor.execute(new HeadersRead());
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
NoopClientStreamListener.java 33 public void headersRead(Metadata headers) {}
ForwardingClientStreamListenerTest.java 56 forward.headersRead(headers);
57 verify(mock).headersRead(same(headers));
Http2ClientStreamTransportStateTest.java 84 verify(mockListener).headersRead(headers);
98 verify(mockListener).headersRead(headers);
111 verify(mockListener, never()).headersRead(any(Metadata.class));
126 verify(mockListener, never()).headersRead(any(Metadata.class));
142 verify(mockListener, never()).headersRead(any(Metadata.class));
168 verify(mockListener).headersRead(headers);
184 verify(mockListener).headersRead(headers);
204 verify(mockListener, never()).headersRead(any(Metadata.class));
247 verify(mockListener, never()).headersRead(any(Metadata.class));
264 verify(mockListener).headersRead(headers)
    [all...]
DelayedStreamTest.java 313 passedListener.headersRead(headers);
323 inOrder.verify(listener).headersRead(headers);
344 delayedListener.headersRead(headers);
345 verify(listener).headersRead(headers);
AbstractClientStreamTest.java 189 verify(mockListener).headersRead(headers);
216 verify(mockListener).headersRead(headers);
231 verify(mockListener).headersRead(headers);
286 verify(mockListener).headersRead(headers);
298 verify(mockListener).headersRead(headers);
ClientCallImplTest.java 157 streamListener.headersRead(new Metadata());
179 streamListener.headersRead(new Metadata());
222 * queued to run. When headersRead is called, an exception will occur and attempt to cancel the
226 streamListener.headersRead(new Metadata());
564 listener.headersRead(new Metadata());
903 streamListener.headersRead(new Metadata());
    [all...]
RetriableStreamTest.java 353 sublistenerCaptor1.getValue().headersRead(new Metadata());
386 // headersRead
387 sublistenerCaptor2.getValue().headersRead(new Metadata());
409 sublistenerCaptor1.getValue().headersRead(new Metadata());
444 // headersRead
445 sublistenerCaptor2.getValue().headersRead(new Metadata());
648 sublistenerCaptor2.get().headersRead(new Metadata());
722 sublistenerCaptor1.getValue().headersRead(new Metadata());
    [all...]
  /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
InProcessTransport.java 413 clientStreamListener.headersRead(headers);
  /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyClientHandlerTest.java 312 verify(streamListener).headersRead(captor.capture());
NettyClientStreamTest.java 250 verify(listener).headersRead(any(Metadata.class));
NettyClientTransportTest.java 685 public void headersRead(Metadata headers) {
  /external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
CronetClientStreamTest.java 245 verify(clientListener).headersRead(metadataCaptor.capture());
    [all...]
  /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
AbstractTransportTest.java 282 verify(mockClientStreamListener2, timeout(250)).headersRead(any(Metadata.class));
    [all...]
  /external/grpc-grpc-java/core/
grpc-core-1.14.0.jar 
  /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
OkHttpClientTransportTest.java     [all...]

Completed in 344 milliseconds