| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerTransportListener.java | 34 void streamCreated(ServerStream stream, String method, Metadata headers); in streamCreated() method
|
| D | ServerImpl.java | 418 public void streamCreated( in streamCreated() method in ServerImpl.ServerTransportListenerImpl
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerImplTest.java | 417 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in methodNotFound()
446 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders); in decompressorNotFound()
499 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in basicExchangeHelper()
705 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in interceptors()
750 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in exceptionInStartCallPropagatesToStream()
912 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in testCallContextIsBoundInListenerCallbacks()
976 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in testClientClose_setup()
1084 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders); in handlerRegistryPriorities()
1090 transportListener.streamCreated(stream, "Service1/Method2", requestHeaders); in handlerRegistryPriorities()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 146 public void streamCreated(ServerStream stream, String method, Metadata headers) { in streamCreated() method in NettyServerHandlerTest.ServerTransportListenerImpl
501 verify(transportListener).streamCreated(streamCaptor.capture(), methodCaptor.capture(), in headersSupportExtensionContentType()
1045 verify(transportListener).streamCreated(streamCaptor.capture(), methodCaptor.capture(), in createStream()
|
| D | NettyClientTransportTest.java | 762 public void streamCreated(ServerStream stream, String method, Metadata headers) { in transportCreated()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 657 serverTransportListener.streamCreated(serverStream, method.getFullMethodName(), headers);
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyServerHandler.java | 437 transportListener.streamCreated(stream, method, metadata); in onHeadersRead()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 1858 public void streamCreated(ServerStream stream, String method, Metadata headers) { in streamCreated() method in AbstractTransportTest.MockServerTransportListener
|