| /external/dagger2/javatests/dagger/grpc/functional/server/ |
| D | FriendlyBarista.java | 41 responseObserver.onCompleted(); in unaryGetCoffee()
60 public void onCompleted() { in clientStreamingGetCoffee() method
63 responseObserver.onCompleted(); in clientStreamingGetCoffee()
74 responseObserver.onCompleted(); in serverStreamingGetCoffee()
89 responseObserver.onCompleted(); in bidiStreamingGetCoffee()
97 public void onCompleted() { in bidiStreamingGetCoffee() method
98 responseObserver.onCompleted(); in bidiStreamingGetCoffee()
|
| D | BaristaTest.java | 70 public void onCompleted() { in onCompleted() method in BaristaTest.CoffeeResponseObserver
119 requestObserver.onCompleted(); in testClientStreamingGetCoffee()
139 requestObserver.onCompleted(); in testBidiStreamingGetCoffee()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 186 requestObserver.onCompleted(); in fileByFilename()
214 requestObserver.onCompleted(); in fileByFilenameConsistentForMutableServices()
220 requestObserver2.onCompleted(); in fileByFilenameConsistentForMutableServices()
225 requestObserver3.onCompleted(); in fileByFilenameConsistentForMutableServices()
255 requestObserver.onCompleted(); in fileContainingSymbol()
290 requestObserver.onCompleted(); in fileContainingNestedSymbol()
317 requestObserver.onCompleted(); in fileContainingSymbolForMutableServices()
323 requestObserver2.onCompleted(); in fileContainingSymbolForMutableServices()
328 requestObserver3.onCompleted(); in fileContainingSymbolForMutableServices()
362 requestObserver.onCompleted(); in fileContainingExtension()
[all …]
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 158 onCompleted(); in runServer()
168 onCompleted(); in runServer()
172 public void onCompleted() { in runServer() method in LoadWorker
179 responseObserver.onCompleted(); in runServer()
210 onCompleted();
220 onCompleted();
224 public void onCompleted() {
231 responseObserver.onCompleted();
244 responseObserver.onCompleted();
253 responseObserver.onCompleted();
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | MoreInProcessTest.java | 86 responseObserver.onCompleted(); in asyncClientStreaming_serverResponsePriorToRequest()
97 public void onCompleted() { in asyncClientStreaming_serverResponsePriorToRequest()
122 public void onCompleted() { in asyncClientStreaming_serverResponsePriorToRequest()
145 responseObserver.onCompleted(); in asyncClientStreaming_serverErrorPriorToRequest()
156 public void onCompleted() { in asyncClientStreaming_serverErrorPriorToRequest()
181 public void onCompleted() { in asyncClientStreaming_serverErrorPriorToRequest()
214 public void onCompleted() { in asyncClientStreaming_erroneousServiceImpl()
240 public void onCompleted() { in asyncClientStreaming_erroneousServiceImpl()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzService.java | 72 responseObserver.onCompleted(); in getTopChannels()
90 responseObserver.onCompleted(); in getChannel()
100 responseObserver.onCompleted(); in getServers()
118 responseObserver.onCompleted(); in getSubchannel()
136 responseObserver.onCompleted(); in getSocket()
150 responseObserver.onCompleted(); in getServerSockets()
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 62 responseObserver.onCompleted(); in store()
72 responseObserver.onCompleted(); in retrieve()
118 public void onCompleted() { in computeMinMax() method in JavaGrpcTest
127 responseObserver.onCompleted(); in computeMinMax()
180 public void onCompleted() {
194 monsterStream.onCompleted();
209 public void onCompleted() {
229 monsterStream.onCompleted();
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 216 responseObserver.onCompleted(); in unaryCall()
229 responseObserver.onCompleted(); in streamingCall()
242 public void onCompleted() { in streamingCall() method in AsyncServer
244 responseObserver.onCompleted(); in streamingCall()
258 responseObserver.onCompleted();
271 public void onCompleted() {
274 responseObserver.onCompleted();
354 public void onCompleted() {
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClientTest.java | 123 responseObserver.onCompleted(); in getFeature()
184 responseObserver.onCompleted(); in listFeatures()
283 public void onCompleted() { in recordRoute()
285 responseObserver.onCompleted(); in recordRoute()
338 public void onCompleted() { in recordRoute_serverError()
384 public void onCompleted() { in routeChat_simpleResponse()
420 responseObserverRef.get().onCompleted(); in routeChat_simpleResponse()
452 public void onCompleted() { in routeChat_echoResponse()
453 responseObserver.onCompleted(); in routeChat_echoResponse()
500 public void onCompleted() { in routeChat_errorResponse()
[all …]
|
| D | RouteGuideServerTest.java | 151 public void onCompleted() { in listFeatures()
195 requestObserver.onCompleted(); in recordRoute()
202 verify(responseObserver, timeout(100)).onCompleted(); in recordRoute()
271 requestObserver.onCompleted(); in routeChat()
272 verify(responseObserver, timeout(100)).onCompleted(); in routeChat()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServer.java | 131 responseObserver.onCompleted(); in getFeature()
158 responseObserver.onCompleted(); in listFeatures()
197 public void onCompleted() { in recordRoute() method
202 responseObserver.onCompleted(); in recordRoute()
236 public void onCompleted() { in routeChat() method in RouteGuideServer
237 responseObserver.onCompleted(); in routeChat()
|
| D | RouteGuideClient.java | 158 public void onCompleted() { in recordRoute()
187 requestObserver.onCompleted(); in recordRoute()
223 public void onCompleted() { in routeChat()
245 requestObserver.onCompleted(); in routeChat()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlServer.java | 113 responseObserver.onCompleted(); in main()
117 public void onCompleted() { in main()
120 responseObserver.onCompleted(); in main()
|
| D | ManualFlowControlClient.java | 86 requestStream.onCompleted(); in main()
107 public void onCompleted() { in main()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 276 public void onCompleted() { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
303 public void onCompleted() { in callStreamObserverPropagatesFlowControlRequestsToCall()
349 public void onCompleted() { in canCaptureInboundFlowControlForServerStreamingObserver()
396 public void onCompleted() { in inprocessTransportInboundFlowControl()
397 serverCallObserver.onCompleted(); in inprocessTransportInboundFlowControl()
431 public void onCompleted() { in inprocessTransportInboundFlowControl()
442 integerStreamObserver.onCompleted(); in inprocessTransportInboundFlowControl()
477 public void onCompleted() { in inprocessTransportOutboundFlowControl()
478 serverCallObserver.onCompleted(); in inprocessTransportOutboundFlowControl()
506 requestStream.onCompleted(); in inprocessTransportOutboundFlowControl()
[all …]
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | ChannelzServiceTest.java | 156 verify(observer).onCompleted(); in getTopChannelHelper()
167 verify(observer).onCompleted(); in getChannelHelper()
188 verify(observer).onCompleted(); in getSubchannelHelper()
211 verify(observer).onCompleted(); in getServersHelper()
232 verify(observer).onCompleted(); in getSocketHelper()
|
| D | HealthStatusManagerTest.java | 70 inOrder.verify(observer, times(1)).onCompleted(); in checkValidStatus()
91 verify(observer, never()).onCompleted(); in checkStatusNotFound()
112 verify(observer, never()).onCompleted(); in notFoundForClearedStatus()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 80 responseObserver.onCompleted(); in emptyCall()
127 responseObserver.onCompleted(); in unaryCall()
157 public void onCompleted() { in streamingInputCall() method
160 responseObserver.onCompleted(); in streamingInputCall()
192 public void onCompleted() { in fullDuplexCall()
222 public void onCompleted() {
335 responseStream.onCompleted();
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStubTest.java | 161 reader.onCompleted(); in onNext()
173 public void onCompleted() { in onCompleted() method in AltsHandshakerStubTest.MockWriter
174 reader.onCompleted(); in onCompleted()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AbstractCoroutineTest.kt | 26 override fun onCompleted(value: String) { in <lambda>() method
66 override fun onCompleted(value: String) { in <lambda>() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | AbstractCoroutine.kt | 82 protected open fun onCompleted(value: T) {} in onCompleted() method
104 onCompleted(state as T) in cancellationExceptionMessage()
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 409 public void onCompleted() { in startUnaryCalls()
417 observer.onCompleted(); in startUnaryCalls()
444 requestObserverRef.get().onCompleted(); in startStreamingCalls()
463 public void onCompleted() { in startStreamingCalls()
499 obs.onCompleted(); in startFlowControlledStreamingCalls()
517 public void onCompleted() { in startFlowControlledStreamingCalls()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 79 writer.onCompleted(); in close()
107 public void onCompleted() { in onCompleted() method in AltsHandshakerStub.Reader
|
| /external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/ |
| D | FakeOcAgentTraceServiceGrpcImplTest.java | 52 public void onCompleted() {}
64 public void onCompleted() {}
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 78 void onCompleted(); in onCompleted() method
|