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

  /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
ServerCallStreamObserver.java 32 public abstract class ServerCallStreamObserver<V> extends CallStreamObserver<V> {
ServerCalls.java 304 extends ServerCallStreamObserver<RespT> {
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlServer.java 22 import io.grpc.stub.ServerCallStreamObserver;
40 final ServerCallStreamObserver<HelloReply> serverCallStreamObserver =
41 (ServerCallStreamObserver<HelloReply>) responseObserver;
42 serverCallStreamObserver.disableAutoInboundFlowControl();
57 serverCallStreamObserver.setOnReadyHandler(new Runnable() {
59 if (serverCallStreamObserver.isReady() && wasReady.compareAndSet(false, true)) {
64 serverCallStreamObserver.request(1);
88 // Check the provided ServerCallStreamObserver to see if it is still ready to accept more messages.
89 if (serverCallStreamObserver.isReady())
    [all...]
  /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
ServerCallsTest.java 89 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver =
90 new AtomicReference<ServerCallStreamObserver<Integer>>();
96 assertTrue(responseObserver instanceof ServerCallStreamObserver);
97 ServerCallStreamObserver<Integer> serverCallObserver =
98 (ServerCallStreamObserver<Integer>) responseObserver;
139 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver =
140 new AtomicReference<ServerCallStreamObserver<Integer>>();
146 callObserver.set((ServerCallStreamObserver<Integer>) responseObserver);
167 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver =
168 new AtomicReference<ServerCallStreamObserver<Integer>>()
    [all...]
ClientCallsTest.java 382 final ServerCallStreamObserver<Integer> serverCallObserver =
383 (ServerCallStreamObserver<Integer>) responseObserver;
453 final SettableFuture<ServerCallStreamObserver<Integer>> observerFuture
461 final ServerCallStreamObserver<Integer> serverCallObserver =
462 (ServerCallStreamObserver<Integer>) responseObserver;
529 ServerCallStreamObserver<Integer> serverCallObserver = observerFuture.get(5, TimeUnit.SECONDS);
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java 28 import io.grpc.stub.ServerCallStreamObserver;
222 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =
223 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
290 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =
291 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
318 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =
319 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
  /external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
ProtoReflectionService.java 43 import io.grpc.stub.ServerCallStreamObserver;
133 final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver =
134 (ServerCallStreamObserver<ServerReflectionResponse>) responseObserver;
136 new ProtoReflectionStreamObserver(updateIndexIfNecessary(), serverCallStreamObserver);
137 serverCallStreamObserver.setOnReadyHandler(requestObserver);
138 serverCallStreamObserver.disableAutoInboundFlowControl();
139 serverCallStreamObserver.request(1);
146 private final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver;
    [all...]
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
CascadingTest.java 41 import io.grpc.stub.ServerCallStreamObserver;
235 ((ServerCallStreamObserver) responseObserver).setOnCancelHandler(new Runnable() {
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
TestServiceImpl.java 29 import io.grpc.stub.ServerCallStreamObserver;
88 ServerCallStreamObserver<SimpleResponse> obs =
89 (ServerCallStreamObserver<SimpleResponse>) responseObserver;

Completed in 4028 milliseconds