| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ForwardingServerCallListenerTest.java | 53 public void onMessage() { in onMessage() method in ForwardingServerCallListenerTest
54 forwarder.onMessage(12345); in onMessage()
56 verify(serverCallListener).onMessage(12345); in onMessage()
|
| D | ContextsTest.java | 60 @Override public void onMessage(Object messageIn) { in interceptCall_basic()
99 wrapped.onMessage(message); in interceptCall_basic()
129 @Override public void onMessage(Object messageIn) { in interceptCall_restoresIfListenerThrows()
159 wrapped.onMessage(new Object()); in interceptCall_restoresIfListenerThrows()
|
| D | ServerInterceptorsTest.java | 318 public void onMessage(Holder message) { in typedMarshalledMessages()
356 public void onMessage(ReqT message) { in typedMarshalledMessages()
359 super.onMessage(message); in typedMarshalledMessages()
385 public void onMessage(ReqT message) { in typedMarshalledMessages()
388 super.onMessage(message); in typedMarshalledMessages()
406 .onMessage(new ByteArrayInputStream(bytes)); in typedMarshalledMessages()
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ServerCallsTest.java | 123 callListener.onMessage(1); in runtimeStreamObserverIsServerCallStreamObserver()
152 callListener.onMessage(1); in cannotSetOnCancelHandlerAfterServiceInvocation()
180 callListener.onMessage(1); in cannotSetOnReadyHandlerAfterServiceInvocation()
208 callListener.onMessage(1); in cannotDisableAutoFlowControlAfterServiceInvocation()
235 callListener.onMessage(1); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
284 callListener.onMessage(1); in onReadyHandlerCalledForUnaryRequest()
343 listener.onMessage(1); in clientSendsOne_errorTooManyRequests_unary()
344 listener.onMessage(1); in clientSendsOne_errorTooManyRequests_unary()
364 listener.onMessage(1); in clientSendsOne_errorTooManyRequests_serverStreaming()
365 listener.onMessage(1); in clientSendsOne_errorTooManyRequests_serverStreaming()
[all …]
|
| D | ClientCallsTest.java | 102 listener.onMessage(resp); in unaryBlockingCallSuccess()
160 listener.get().onMessage("bar"); in unaryFutureCallSuccess()
213 listener.get().onMessage("bar"); in unaryFutureCallCancelled()
280 listener.get().onMessage("message"); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
323 listener.get().onMessage("message"); in callStreamObserverPropagatesFlowControlRequestsToCall()
367 listener.get().onMessage("message"); in canCaptureInboundFlowControlForServerStreamingObserver()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ClientInterceptorTest.cs | 191 readonly Func<T, T> onMessage; field in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.WrappedClientStreamWriter
193 …public WrappedClientStreamWriter(IClientStreamWriter<T> writer, Func<T, T> onMessage, Action onRes… in WrappedClientStreamWriter() argument
196 this.onMessage = onMessage; in WrappedClientStreamWriter()
209 if (onMessage != null) in WriteAsync()
211 message = onMessage(message); in WriteAsync()
|
| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClientTest.java | 131 verify(testHelper).onMessage(responseFeature); in getFeature()
196 verify(testHelper).onMessage(responseFeature1); in listFeatures()
197 verify(testHelper).onMessage(responseFeature2); in listFeatures()
235 verify(testHelper).onMessage(responseFeature1); in listFeatures_error()
304 verify(testHelper).onMessage(fakeResponse); in recordRoute()
415 verify(testHelper).onMessage(fakeResponse1); in routeChat_simpleResponse()
417 verify(testHelper).onMessage(fakeResponse2); in routeChat_simpleResponse()
467 verify(testHelper).onMessage(notesDelivered.get(i)); in routeChat_echoResponse()
513 verify(testHelper, never()).onMessage(any(Message.class)); in routeChat_errorResponse()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/services/ |
| D | BinaryLogProviderTest.java | 153 public void onMessage(Integer message) { in wrapChannel_handler()
194 listener.onMessage(request); in onClientMessageHelper()
240 public void onMessage(String message) { in wrapMethodDefinition_handler()
284 listener.onMessage(request); in onServerMessageHelper()
318 public void onMessage(RespT message) { in interceptCall()
325 super.onMessage(dup); in interceptCall()
371 public void onMessage(ReqT message) {
378 super.onMessage(dup);
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/util/ |
| D | UtilServerInterceptorsTest.java | 84 public void onMessage(Void message) { in statusRuntimeExceptionTransmitter()
114 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onMessage(null); in statusRuntimeExceptionTransmitter()
135 public void onMessage(Void message) { in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
150 callDoubleSreListener.onMessage(null); // the only close with our exception in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideClient.java | 78 testHelper.onMessage(feature); in getFeature()
118 testHelper.onMessage(feature); in listFeatures()
144 testHelper.onMessage(summary); in recordRoute()
209 testHelper.onMessage(note); in routeChat()
315 void onMessage(Message message); in onMessage() method
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ForwardingServerCallListener.java | 32 public void onMessage(ReqT message) { in onMessage() method in ForwardingServerCallListener
33 delegate().onMessage(message); in onMessage()
|
| D | ForwardingClientCallListener.java | 32 public void onMessage(RespT message) { in onMessage() method in ForwardingClientCallListener
33 delegate().onMessage(message); in onMessage()
|
| D | Contexts.java | 73 public void onMessage(ReqT message) { in onMessage() method in Contexts.ContextualizedServerCallListener
76 super.onMessage(message); in onMessage()
|
| D | ClientInterceptors.java | 115 public void onMessage(WRespT wMessage) { in wrapClientInterceptor()
118 responseListener.onMessage(message); in wrapClientInterceptor()
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | WebSocketReaderTest.java | 156 @Override public void onMessage(ResponseBody message) throws IOException { in serverHelloTwoChunks()
257 @Override public void onMessage(ResponseBody body) throws IOException { in noCloseErrors()
275 @Override public void onMessage(ResponseBody message) throws IOException { in closeExhaustsMessage()
297 @Override public void onMessage(ResponseBody message) throws IOException { in closeExhaustsMessageOverControlFrames()
317 @Override public void onMessage(ResponseBody message) throws IOException { in closedMessageSourceThrows()
|
| /external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/ |
| D | AutobahnTester.java | 85 @Override public void onMessage(final ResponseBody message) throws IOException { in runTest()
139 @Override public void onMessage(ResponseBody message) throws IOException { in getTestCount()
176 @Override public void onMessage(ResponseBody message) throws IOException { in updateReports()
|
| /external/perfetto/ui/src/common/ |
| D | wasm_engine_proxy.ts | 86 this.worker.onmessage = this.onMessage.bind(this);
116 onMessage(m: MessageEvent) { method in WasmEngineProxy
|
| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
| D | WebSocketRecorder.java | 36 void onMessage(ResponseBody message) throws IOException; in onMessage() method
50 @Override public void onMessage(ResponseBody message) throws IOException { in onMessage() method in WebSocketRecorder
52 delegate.onMessage(message); in onMessage()
|
| D | WebSocketCallTest.java | 222 @Override public void onMessage(ResponseBody message) throws IOException { in awaitWebSocket()
223 listener.onMessage(message); in awaitWebSocket()
256 @Override public void onMessage(ResponseBody message) throws IOException { in onMessage() method in WebSocketCallTest.EmptyWebSocketListener
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptor.java | 228 public void onMessage(RespT message) {
233 super.onMessage(message);
275 interceptedListener.onMessage((RespT) cachedResponse.response);
|
| /external/autotest/client/site_tests/power_LoadTest/extension/ |
| D | test.js | 260 chrome.runtime.onMessage.removeListener(testListener);
294 chrome.runtime.onMessage.addListener(testListener);
302 chrome.runtime.onMessage.addListener(testListener);
|
| /external/autotest/client/site_tests/policy_DisableScreenshots/Screenshooter/ |
| D | content.js | 1 chrome.runtime.onMessage.addListener((msg, sender, sendResponse) => {
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocket.java | 61 @Override public void onMessage(ResponseBody message) throws IOException { in RealWebSocket()
62 listener.onMessage(message); in RealWebSocket()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 63 public void onMessage(ReqT message) { in interceptCall()
65 super.onMessage(message); in interceptCall()
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketListener.java | 55 void onMessage(ResponseBody message) throws IOException; in onMessage() method
|