Searched refs:ServerCallStreamObserver (Results 1 – 9 of 9) sorted by relevance
89 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver = in runtimeStreamObserverIsServerCallStreamObserver()90 new AtomicReference<ServerCallStreamObserver<Integer>>(); in runtimeStreamObserverIsServerCallStreamObserver()96 assertTrue(responseObserver instanceof ServerCallStreamObserver); in runtimeStreamObserverIsServerCallStreamObserver()97 ServerCallStreamObserver<Integer> serverCallObserver = in runtimeStreamObserverIsServerCallStreamObserver()98 (ServerCallStreamObserver<Integer>) responseObserver; in runtimeStreamObserverIsServerCallStreamObserver()139 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver = in cannotSetOnCancelHandlerAfterServiceInvocation()140 new AtomicReference<ServerCallStreamObserver<Integer>>(); in cannotSetOnCancelHandlerAfterServiceInvocation()146 callObserver.set((ServerCallStreamObserver<Integer>) responseObserver); in cannotSetOnCancelHandlerAfterServiceInvocation()167 final AtomicReference<ServerCallStreamObserver<Integer>> callObserver = in cannotSetOnReadyHandlerAfterServiceInvocation()168 new AtomicReference<ServerCallStreamObserver<Integer>>(); in cannotSetOnReadyHandlerAfterServiceInvocation()[all …]
382 final ServerCallStreamObserver<Integer> serverCallObserver = in inprocessTransportInboundFlowControl()383 (ServerCallStreamObserver<Integer>) responseObserver; in inprocessTransportInboundFlowControl()453 final SettableFuture<ServerCallStreamObserver<Integer>> observerFuture in inprocessTransportOutboundFlowControl()461 final ServerCallStreamObserver<Integer> serverCallObserver = in inprocessTransportOutboundFlowControl()462 (ServerCallStreamObserver<Integer>) responseObserver; in inprocessTransportOutboundFlowControl()529 ServerCallStreamObserver<Integer> serverCallObserver = observerFuture.get(5, TimeUnit.SECONDS); in inprocessTransportOutboundFlowControl()
28 import io.grpc.stub.ServerCallStreamObserver;222 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver = in streamingCall()223 (ServerCallStreamObserver<Messages.SimpleResponse>) observer; in streamingCall()290 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =291 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;318 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver =319 (ServerCallStreamObserver<Messages.SimpleResponse>) observer;
22 import io.grpc.stub.ServerCallStreamObserver;40 final ServerCallStreamObserver<HelloReply> serverCallStreamObserver = in main()41 (ServerCallStreamObserver<HelloReply>) responseObserver; in main()
43 import io.grpc.stub.ServerCallStreamObserver;133 final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver = in serverReflectionInfo()134 (ServerCallStreamObserver<ServerReflectionResponse>) responseObserver; in serverReflectionInfo()146 private final ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver;153 ServerCallStreamObserver<ServerReflectionResponse> serverCallStreamObserver) { in ProtoReflectionStreamObserver()
32 public abstract class ServerCallStreamObserver<V> extends CallStreamObserver<V> { class
304 extends ServerCallStreamObserver<RespT> {
29 import io.grpc.stub.ServerCallStreamObserver;88 ServerCallStreamObserver<SimpleResponse> obs = in unaryCall()89 (ServerCallStreamObserver<SimpleResponse>) responseObserver; in unaryCall()
41 import io.grpc.stub.ServerCallStreamObserver;235 ((ServerCallStreamObserver) responseObserver).setOnCancelHandler(new Runnable() { in startChainingServer()