Home
last modified time | relevance | path

Searched refs:ServerStreamListener (Results 1 – 12 of 12) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerImplTest.java186 private ArgumentCaptor<ServerStreamListener> streamListenerCaptor;
418 verify(stream).setListener(isA(ServerStreamListener.class)); in methodNotFound()
501 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in basicExchangeHelper()
752 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in exceptionInStartCallPropagatesToStream()
914 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testCallContextIsBoundInListenerCallbacks()
939 private ServerStreamListener testClientClose_setup( in testClientClose_setup()
978 ServerStreamListener streamListener = streamListenerCaptor.getValue(); in testClientClose_setup()
993 ServerStreamListener streamListener = testClientClose_setup(callReference, in testClientClose_cancelTriggersImmediateCancellation()
1016 ServerStreamListener streamListener = testClientClose_setup(callReference, in testClientClose_OkTriggersDelayedCancellation()
1106 ServerStreamListener mockListener = mock(ServerStreamListener.class); in messageRead_errorCancelsCall()
[all …]
DAbstractServerStreamTest.java204 ServerStreamListener streamListener = mock(ServerStreamListener.class); in listenerReady_readyCalled()
333 private static class ServerStreamListenerBase implements ServerStreamListener {
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractServerStream.java175 public final void setListener(ServerStreamListener serverStreamListener) { in setListener()
191 private ServerStreamListener listener;
217 public final void setListener(ServerStreamListener listener) { in setListener()
251 protected ServerStreamListener listener() { in listener()
DServerImpl.java83 private static final ServerStreamListener NOOP_LISTENER = new NoopListener();
462 ServerStreamListener listener = NOOP_LISTENER; in streamCreated()
528 private <ReqT, RespT> ServerStreamListener startCall(ServerStream stream, String fullMethodName, in startCall()
547 private <WReqT, WRespT> ServerStreamListener startWrappedCall( in startWrappedCall()
596 private static final class NoopListener implements ServerStreamListener {
633 static final class JumpToApplicationThreadServerStreamListener implements ServerStreamListener {
639 private ServerStreamListener listener;
652 private ServerStreamListener getListener() { in getListener()
660 void setListener(ServerStreamListener listener) { in setListener()
DServerStreamListener.java22 public interface ServerStreamListener extends StreamListener { interface
DServerStream.java88 void setListener(ServerStreamListener serverStreamListener); in setListener()
DServerCallImpl.java192 ServerStreamListener newServerStreamListener(ServerCall.Listener<ReqT> listener) { in newServerStreamListener()
227 static final class ServerStreamListenerImpl<ReqT> implements ServerStreamListener {
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java49 import io.grpc.internal.ServerStreamListener;
328 public void setListener(ServerStreamListener serverStreamListener) {
501 private ServerStreamListener serverStreamListener;
519 private synchronized void setListener(ServerStreamListener listener) {
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyServerStreamTest.java40 import io.grpc.internal.ServerStreamListener;
66 protected ServerStreamListener serverListener;
311 protected ServerStreamListener listener() { in listener()
DNettyClientTransportTest.java59 import io.grpc.internal.ServerStreamListener;
716 private static final class EchoServerStreamListener implements ServerStreamListener {
DNettyServerHandlerTest.java64 import io.grpc.internal.ServerStreamListener;
119 private ServerStreamListener streamListener;
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DAbstractTransportTest.java67 import io.grpc.internal.ServerStreamListener;
1895 private static class ServerStreamListenerBase implements ServerStreamListener {