Searched refs:NoopStreamObserver (Results 1 – 3 of 3) sorted by relevance
113 return new ServerCalls.NoopStreamObserver<Integer>(); in runtimeStreamObserverIsServerCallStreamObserver()147 return new ServerCalls.NoopStreamObserver<Integer>(); in cannotSetOnCancelHandlerAfterServiceInvocation()175 return new ServerCalls.NoopStreamObserver<Integer>(); in cannotSetOnReadyHandlerAfterServiceInvocation()203 return new ServerCalls.NoopStreamObserver<Integer>(); in cannotDisableAutoFlowControlAfterServiceInvocation()227 return new ServerCalls.NoopStreamObserver<Integer>(); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()396 return new ServerCalls.NoopStreamObserver<Integer>() { in inprocessTransportManualFlow()
41 import io.grpc.stub.ServerCalls.NoopStreamObserver;228 new NoopStreamObserver<String>()); in cannotSetOnReadyAfterCallStarted()394 return new ServerCalls.NoopStreamObserver<Integer>() { in inprocessTransportInboundFlowControl()
423 return new NoopStreamObserver<T>(); in asyncUnimplementedStreamingCall()430 static class NoopStreamObserver<V> implements StreamObserver<V> { class in ServerCalls