Home
last modified time | relevance | path

Searched refs:requestObserver (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java183 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilename() local
185 requestObserver.onNext(request); in fileByFilename()
186 requestObserver.onCompleted(); in fileByFilename()
210 StreamObserver<ServerReflectionRequest> requestObserver = in fileByFilenameConsistentForMutableServices() local
213 requestObserver.onNext(request); in fileByFilenameConsistentForMutableServices()
214 requestObserver.onCompleted(); in fileByFilenameConsistentForMutableServices()
252 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingSymbol() local
254 requestObserver.onNext(request); in fileContainingSymbol()
255 requestObserver.onCompleted(); in fileContainingSymbol()
287 StreamObserver<ServerReflectionRequest> requestObserver = in fileContainingNestedSymbol() local
[all …]
/external/dagger2/javatests/dagger/grpc/functional/server/
DBaristaTest.java114 StreamObserver<CoffeeRequest> requestObserver = in testClientStreamingGetCoffee() local
116 requestObserver.onNext(request(POUR_OVER, LATTE)); in testClientStreamingGetCoffee()
117 requestObserver.onNext(request(AMERICANO)); in testClientStreamingGetCoffee()
118 requestObserver.onNext(request(DRIP, ESPRESSO)); in testClientStreamingGetCoffee()
119 requestObserver.onCompleted(); in testClientStreamingGetCoffee()
134 StreamObserver<CoffeeRequest> requestObserver = in testBidiStreamingGetCoffee() local
136 requestObserver.onNext(request(POUR_OVER, LATTE)); in testBidiStreamingGetCoffee()
137 requestObserver.onNext(request(AMERICANO)); in testBidiStreamingGetCoffee()
138 requestObserver.onNext(request(DRIP, ESPRESSO)); in testBidiStreamingGetCoffee()
139 requestObserver.onCompleted(); in testBidiStreamingGetCoffee()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
DRouteGuideServerTest.java186 StreamObserver<Point> requestObserver = stub.recordRoute(responseObserver); in recordRoute() local
188 requestObserver.onNext(p1); in recordRoute()
189 requestObserver.onNext(p2); in recordRoute()
190 requestObserver.onNext(p3); in recordRoute()
191 requestObserver.onNext(p4); in recordRoute()
195 requestObserver.onCompleted(); in recordRoute()
223 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat() local
226 requestObserver.onNext(n1); in routeChat()
229 requestObserver.onNext(n2); in routeChat()
232 requestObserver.onNext(n3); in routeChat()
[all …]
DRouteGuideClientTest.java272 StreamObserver<Point> requestObserver = new StreamObserver<Point>() { in recordRoute()
289 return requestObserver; in recordRoute()
328 StreamObserver<Point> requestObserver = new StreamObserver<Point>() { in recordRoute_serverError()
341 return requestObserver; in recordRoute_serverError()
372 StreamObserver<RouteNote> requestObserver = new StreamObserver<RouteNote>() { in routeChat_simpleResponse()
389 return requestObserver; in routeChat_simpleResponse()
439 StreamObserver<RouteNote> requestObserver = new StreamObserver<RouteNote>() { in routeChat_echoResponse()
457 return requestObserver; in routeChat_echoResponse()
488 StreamObserver<RouteNote> requestObserver = new StreamObserver<RouteNote>() { in routeChat_errorResponse()
505 return requestObserver; in routeChat_errorResponse()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java221 StreamObserver<ReqT> requestObserver = method.invoke(responseObserver); in startCall() local
226 return new StreamingServerCallListener(requestObserver, responseObserver, call); in startCall()
231 private final StreamObserver<ReqT> requestObserver; field in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
238 StreamObserver<ReqT> requestObserver, in StreamingServerCallListener() argument
241 this.requestObserver = requestObserver; in StreamingServerCallListener()
248 requestObserver.onNext(request); in onMessage()
259 requestObserver.onCompleted(); in onHalfClose()
269 requestObserver.onError( in onCancel()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
DRouteGuideClient.java164 StreamObserver<Point> requestObserver = asyncStub.recordRoute(responseObserver); in recordRoute() local
172 requestObserver.onNext(point); in recordRoute()
183 requestObserver.onError(e); in recordRoute()
187 requestObserver.onCompleted(); in recordRoute()
202 StreamObserver<RouteNote> requestObserver = in routeChat() local
237 requestObserver.onNext(request); in routeChat()
241 requestObserver.onError(e); in routeChat()
245 requestObserver.onCompleted(); in routeChat()
/external/grpc-grpc-java/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/
DRouteGuideActivity.java309 StreamObserver<Point> requestObserver = asyncStub.recordRoute(responseObserver); in recordRoute() local
321 requestObserver.onNext(point); in recordRoute()
332 requestObserver.onError(e); in recordRoute()
336 requestObserver.onCompleted(); in recordRoute()
369 StreamObserver<RouteNote> requestObserver = in routeChat() local
410 requestObserver.onNext(request); in routeChat()
414 requestObserver.onError(e); in routeChat()
418 requestObserver.onCompleted(); in routeChat()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncClient.java200 StreamObserver<SimpleRequest> requestObserver = stub.streamingCall(responseObserver); in doStreamingCalls() local
201 responseObserver.requestObserver = requestObserver; in doStreamingCalls()
202 requestObserver.onNext(request); in doStreamingCalls()
218 StreamObserver<SimpleRequest> requestObserver; field in AsyncClient.ThisIsAHackStreamObserver
238 requestObserver.onNext(request); in onNext()
240 requestObserver.onCompleted(); in onNext()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java437 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startStreamingCalls() local
467 requestObserverRef.set(requestObserver); in startStreamingCalls()
468 requestObserver.onNext(request.slice()); in startStreamingCalls()
469 requestObserver.onNext(request.slice()); in startStreamingCalls()
491 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startFlowControlledStreamingCalls() local
521 requestObserverRef.set(requestObserver); in startFlowControlledStreamingCalls()
525 requestObserver.onNext(request.slice()); in startFlowControlledStreamingCalls()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DAbstractInteropTest.java566 StreamObserver<StreamingInputCallRequest> requestObserver = in clientStreaming() local
569 requestObserver.onNext(request); in clientStreaming()
571 requestObserver.onCompleted(); in clientStreaming()
602 StreamObserver<StreamingInputCallRequest> requestObserver = in clientCompressedStreaming() local
608 requestObserver.onNext(expectCompressedRequest); in clientCompressedStreaming()
715 StreamObserver<StreamingOutputCallRequest> requestObserver in pingPong() local
734 requestObserver.onNext(requests.get(i)); in pingPong()
742 requestObserver.onCompleted(); in pingPong()
749 StreamObserver<StreamingOutputCallRequest> requestObserver in emptyStream() local
751 requestObserver.onCompleted(); in emptyStream()
[all …]
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadClient.java381 final AtomicReference<StreamObserver<Messages.SimpleRequest>> requestObserver = in run() local
383 requestObserver.set(stub.streamingCall( in run()
391 requestObserver.get().onCompleted(); in run()
395 requestObserver.get().onNext(simpleRequest); in run()
412 requestObserver.get().onNext(simpleRequest); in run()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java201 StreamObserver<StreamingInputCallRequest> requestObserver = in asyncClientStreaming_erroneousServiceImpl()
217 return requestObserver; in asyncClientStreaming_erroneousServiceImpl()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DProtoReflectionService.java135 ProtoReflectionStreamObserver requestObserver = in serverReflectionInfo() local
137 serverCallStreamObserver.setOnReadyHandler(requestObserver); in serverReflectionInfo()
140 return requestObserver; in serverReflectionInfo()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java320 CallStreamObserver<Integer> requestObserver = in callStreamObserverPropagatesFlowControlRequestsToCall() local
324 requestObserver.request(5); in callStreamObserverPropagatesFlowControlRequestsToCall()
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java186 StreamObserver<LoadBalanceRequest> requestObserver = in setUp()
195 doAnswer(closeRpc).when(requestObserver).onCompleted(); in setUp()
196 lbRequestObservers.add(requestObserver); in setUp()
197 return requestObserver; in setUp()