Searched refs:transportExecutor (Results 1 – 6 of 6) sorted by relevance
41 private final TransportExecutor transportExecutor; field in ApplicationThreadDeframer48 TransportExecutor transportExecutor, in ApplicationThreadDeframer() argument51 this.transportExecutor = checkNotNull(transportExecutor, "transportExecutor"); in ApplicationThreadDeframer()135 transportExecutor.runOnTransportThread( in bytesRead()154 transportExecutor.runOnTransportThread( in deframerClosed()165 transportExecutor.runOnTransportThread( in deframeFailed()
47 private TransportExecutor transportExecutor = new TransportExecutor(); field in ApplicationThreadDeframerTest49 new ApplicationThreadDeframer(listener, transportExecutor, mockDeframer);95 transportExecutor.runStoredRunnable(); in bytesReadInvokesTransportExecutor()103 transportExecutor.runStoredRunnable(); in deframerClosedInvokesTransportExecutor()112 transportExecutor.runStoredRunnable(); in deframeFailedInvokesTransportExecutor()
151 private Executor transportExecutor; field in OkHttpChannelBuilder183 public final OkHttpChannelBuilder transportExecutor(@Nullable Executor transportExecutor) { in transportExecutor() method in OkHttpChannelBuilder184 this.transportExecutor = transportExecutor; in transportExecutor()399 return new OkHttpTransportFactory(transportExecutor, scheduledExecutorService, in buildTransportFactory()
120 public AndroidChannelBuilder transportExecutor(@Nullable Executor transportExecutor) { in transportExecutor() method in AndroidChannelBuilder124 .invoke(delegateBuilder, transportExecutor); in transportExecutor()
5 io.grpc.okhttp.OkHttpChannelBuilder transportExecutor(java.util.concurrent.Executor);
104 public void transportExecutor() { in transportExecutor() method in AndroidChannelBuilderTest106 .transportExecutor( in transportExecutor()