Searched refs:ConnectionClientTransport (Results 1 – 19 of 19) sorted by relevance
44 final ConnectionClientTransport transport;51 MockClientTransportInfo(ConnectionClientTransport transport, in MockClientTransportInfo()74 doAnswer(new Answer<ConnectionClientTransport>() { in captureTransports()76 public ConnectionClientTransport answer(InvocationOnMock invocation) throws Throwable { in captureTransports()77 final ConnectionClientTransport mockTransport = mock(ConnectionClientTransport.class); in captureTransports()
443 ConnectionClientTransport mockTransport = transportInfo.transport; in subtestCallsAndShutdown()644 ConnectionClientTransport mockTransport = transportInfo.transport; in callOptionsExecutor()1425 final ConnectionClientTransport transport = transportInfo.transport; in informationPropagatedToNewStreamAndCallCredentials()1899 ConnectionClientTransport mockTransport = transportInfo.transport; in idleMode_resetsDelayedTransportPicker()1968 ConnectionClientTransport mockTransport = transportInfo.transport; in enterIdle_exitsIdleIfDelayedStreamPending()1998 ConnectionClientTransport mockTransport = transportInfo.transport; in updateBalancingStateDoesUpdatePicker()2487 ConnectionClientTransport mockTransport = transportInfo.transport; in channelsAndSubchannels_oob_instrumented0()2651 ConnectionClientTransport mockTransport = transportInfo.transport; in retryBackoffThenChannelShutdown_retryShouldStillHappen_newCallShouldFail()
63 private ConnectionClientTransport mockTransport;
48 @Mock private ConnectionClientTransport transport;
128 private final Collection<ConnectionClientTransport> transports = new ArrayList<>();131 private final InUseStateAggregator<ConnectionClientTransport> inUseStateAggregator =132 new InUseStateAggregator<ConnectionClientTransport>() {149 private ConnectionClientTransport pendingTransport;239 ConnectionClientTransport transport = in startNewTransport()389 ConnectionClientTransport savedPendingTransport; in shutdown()446 final ConnectionClientTransport transport, final boolean inUse) { in handleTransportInUseState()537 final ConnectionClientTransport transport;540 TransportListener(ConnectionClientTransport transport, SocketAddress address) { in TransportListener()674 private final ConnectionClientTransport delegate;[all …]
44 public ConnectionClientTransport newClientTransport( in newClientTransport()61 private final ConnectionClientTransport delegate;64 CallCredentialsApplyingTransport(ConnectionClientTransport delegate, String authority) { in CallCredentialsApplyingTransport()70 protected ConnectionClientTransport delegate() { in delegate()
30 abstract class ForwardingConnectionClientTransport implements ConnectionClientTransport {77 protected abstract ConnectionClientTransport delegate(); in delegate()
260 private final ConnectionClientTransport transport;262 public ClientKeepAlivePinger(ConnectionClientTransport transport) { in ClientKeepAlivePinger()
26 public interface ConnectionClientTransport extends ManagedClientTransport { interface
36 ConnectionClientTransport newClientTransport( in newClientTransport()
25 import io.grpc.internal.ConnectionClientTransport;172 public ConnectionClientTransport newClientTransport( in newClientTransport()
43 import io.grpc.internal.ConnectionClientTransport;71 final class InProcessTransport implements ServerTransport, ConnectionClientTransport {
33 import io.grpc.internal.ConnectionClientTransport;48 class CronetClientTransport implements ConnectionClientTransport {
31 import io.grpc.internal.ConnectionClientTransport;231 public ConnectionClientTransport newClientTransport( in newClientTransport()
35 import io.grpc.internal.ConnectionClientTransport;64 class NettyClientTransport implements ConnectionClientTransport {
36 import io.grpc.internal.ConnectionClientTransport;503 public ConnectionClientTransport newClientTransport( in newClientTransport()
33 import io.grpc.internal.ConnectionClientTransport;518 public ConnectionClientTransport newClientTransport( in newClientTransport()
48 import io.grpc.internal.ConnectionClientTransport;102 class OkHttpClientTransport implements ConnectionClientTransport, TransportExceptionHandler {
61 import io.grpc.internal.ConnectionClientTransport;343 assumeTrue(client instanceof ConnectionClientTransport); in checkClientAttributes()344 ConnectionClientTransport connectionClient = (ConnectionClientTransport) client; in checkClientAttributes()