Home
last modified time | relevance | path

Searched defs:onReady (Results 1 – 25 of 35) sorted by relevance

12

/external/sdk-platform-java/gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/
DGrpcDirectStreamController.java55 private final Runnable onReady; field in GrpcDirectStreamController
69 Runnable onReady) { in GrpcDirectStreamController()
153 public void onReady() { in onReady() method in GrpcDirectStreamController.ResponseObserverAdapter
DGrpcExceptionBidiStreamingCallable.java61 ClientStreamReadyObserver<RequestT> onReady, in internalCall()
DGrpcDirectBidiStreamingCallable.java59 final ClientStreamReadyObserver<RequestT> onReady, in internalCall()
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/tracing/
DTracedBidiCallableTest.java189 ClientStreamReadyObserver<String> onReady; field in TracedBidiCallableTest.FakeBidiCallable
196 ClientStreamReadyObserver<String> onReady, in internalCall()
252 public void onReady(ClientStream<String> stream) { in onReady() method in TracedBidiCallableTest.FakeBidiObserver
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/
DClientStreamReadyObserver.java35 void onReady(ClientStream<V> stream); in onReady() method
DBidiStreamingCallable.java53 ClientStreamReadyObserver<RequestT> onReady, in internalCall()
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/
DTracedBidiCallable.java71 ClientStreamReadyObserver<RequestT> onReady, in internalCall()
111 public void onReady(ClientStream<RequestT> stream) { in onReady() method in TracedBidiCallable.TracedClientStreamReadyObserver
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DStreamListener.java46 void onReady(); in onReady() method
DForwardingClientStreamListener.java43 public void onReady() { in onReady() method in ForwardingClientStreamListener
/external/grpc-grpc-java/api/src/main/java/io/grpc/
DPartialForwardingServerCallListener.java49 public void onReady() { in onReady() method in PartialForwardingServerCallListener
DPartialForwardingClientCallListener.java43 public void onReady() { in onReady() method in PartialForwardingClientCallListener
DClientCall.java171 public void onReady() {} in onReady() method in ClientCall.Listener
DServerCall.java100 public void onReady() {} in onReady() method in ServerCall.Listener
DContexts.java113 public void onReady() { in onReady() method in Contexts.ContextualizedServerCallListener
/external/grpc-grpc-java/core/src/testFixtures/java/io/grpc/internal/
DNoopClientStreamListener.java30 public void onReady() {} in onReady() method in NoopClientStreamListener
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/grpcproxy/
DGrpcProxy.java117 @Override public void onReady() { in onReady() method in GrpcProxy.CallProxy.RequestProxy
161 @Override public void onReady() { in onReady() method in GrpcProxy.CallProxy.ResponseProxy
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java99 public void onReady() { in interceptCall() method
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/
DBidiStreamingCallableTest.java150 public void onReady(ClientStream<Integer> stream) { in onReady() method in BidiStreamingCallableTest.AccumulatingBidiObserver
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/
DCronetClientTransportTest.java164 public void onReady() {} in onReady() method in CronetClientTransportTest.BaseClientStreamListener
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java203 public void onReady() { in onReady() method in ServerCalls.UnaryServerCallHandler.UnaryServerCallListener
296 public void onReady() { in onReady() method in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DDelayedStreamTest.java368 public void onReady() { in listener_onReadyDelayedUntilPassthrough() method in DelayedStreamTest.IsReadyListener
DAbstractServerStreamTest.java388 public void onReady() {} in onReady() method in AbstractServerStreamTest.ServerStreamListenerBase
/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/internal/
DBinderClientTransportTest.java374 public void onReady() { in onReady() method in BinderClientTransportTest.TestStreamListener
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientTransportTest.java875 public void onReady() { in onReady() method in NettyClientTransportTest.TestClientStreamListener
899 public void onReady() { in onReady() method in NettyClientTransportTest.EchoServerStreamListener
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/testing/
DFakeStreamingApi.java72 ClientStreamReadyObserver<RequestT> onReady, in internalCall()

12