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

  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DelayedClientTransportTest.java 69 @Mock private ManagedClientTransport.Listener transportListener;
115 delayedTransport.start(transportListener);
149 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS));
150 verify(transportListener).transportTerminated();
159 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS));
160 verify(transportListener).transportTerminated();
162 verifyNoMoreInteractions(transportListener);
168 verify(transportListener).transportShutdown(same(SHUTDOWN_STATUS));
169 verify(transportListener).transportTerminated();
180 verify(transportListener).transportShutdown(any(Status.class))
    [all...]
ServerImplTest.java 409 ServerTransportListener transportListener
411 transportListener.transportReady(Attributes.EMPTY);
417 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders);
436 ServerTransportListener transportListener
438 transportListener.transportReady(Attributes.EMPTY);
446 transportListener.streamCreated(stream, "Waiter/nonexist", requestHeaders);
489 ServerTransportListener transportListener
491 transportListener.transportReady(Attributes.EMPTY);
499 transportListener.streamCreated(stream, "Waiter/serve", requestHeaders);
624 ServerTransportListener transportListener
    [all...]
ManagedChannelImplTest.java 445 ManagedClientTransport.Listener transportListener = transportInfo.listener;
450 transportListener.transportReady();
541 transportListener.transportShutdown(Status.UNAVAILABLE);
544 transportListener.transportTerminated();
645 ManagedClientTransport.Listener transportListener = transportInfo.listener;
648 transportListener.transportReady();
669 transportListener.transportShutdown(Status.UNAVAILABLE);
670 transportListener.transportTerminated();
    [all...]
  /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/
OkHttpClientTransportTest.java 146 private ManagedClientTransport.Listener transportListener;
218 clientTransport.start(transportListener);
296 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class));
297 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated();
322 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class));
323 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated();
338 verify(transportListener, timeout(TIME_OUT_MS)).transportShutdown(isA(Status.class));
339 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated();
379 verify(transportListener).transportShutdown(isA(Status.class));
380 verify(transportListener, timeout(TIME_OUT_MS)).transportTerminated()
    [all...]
  /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
NettyServerHandler.java 105 private final ServerTransportListener transportListener;
133 ServerTransportListener transportListener,
159 transportListener,
180 ServerTransportListener transportListener,
224 transportListener,
238 ServerTransportListener transportListener,
301 this.transportListener = checkNotNull(transportListener, "transportListener");
437 transportListener.streamCreated(stream, method, metadata)
    [all...]
NettyServerTransport.java 253 ServerTransportListener transportListener, ChannelPromise channelUnused) {
255 transportListener,
NettyServer.java 209 ServerTransportListener transportListener;
220 transportListener = listener.transportCreated(transport);
238 transport.start(transportListener);
NettyClientTransport.java 182 public Runnable start(Listener transportListener) {
184 Preconditions.checkNotNull(transportListener, "listener"));
234 // Use a Runnable since lifecycleManager calls transportListener
  /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
NettyServerHandlerTest.java 124 private final ServerTransportListener transportListener =
208 verify(transportListener, never()).transportReady(any(Attributes.class));
213 verify(transportListener).transportReady(any(Attributes.class));
501 verify(transportListener).streamCreated(streamCaptor.capture(), methodCaptor.capture(),
    [all...]
  /external/grpc-grpc-java/netty/shaded/
grpc-netty-shaded-1.14.0.jar 

Completed in 1600 milliseconds