Searched refs:clientResponseObserver (Results 1 – 3 of 3) sorted by relevance
529 FlowControlClientResponseObserver clientResponseObserver = in flowControl() local533 stub.serverReflectionInfo(clientResponseObserver); in flowControl()537 assertEquals(1, clientResponseObserver.getResponses().size()); in flowControl()538 assertEquals(flowControlGoldenResponse, clientResponseObserver.getResponses().get(0)); in flowControl()542 assertEquals(1, clientResponseObserver.getResponses().size()); in flowControl()545 assertEquals(2, clientResponseObserver.getResponses().size()); in flowControl()546 assertEquals(flowControlGoldenResponse, clientResponseObserver.getResponses().get(1)); in flowControl()549 assertTrue(clientResponseObserver.onCompleteCalled()); in flowControl()554 FlowControlClientResponseObserver clientResponseObserver = in flowControlOnCompleteWithPendingRequest() local558 stub.serverReflectionInfo(clientResponseObserver); in flowControlOnCompleteWithPendingRequest()[all …]
47 ClientResponseObserver<HelloRequest, HelloReply> clientResponseObserver = in main() local114 stub.sayHelloStreaming(clientResponseObserver); in main()
402 ClientResponseObserver<ReqT, RespT> clientResponseObserver = in StreamObserverToCallListenerAdapter() local404 clientResponseObserver.beforeStart(adapter); in StreamObserverToCallListenerAdapter()