Home
last modified time | relevance | path

Searched refs:onMessage (Results 1 – 25 of 59) sorted by relevance

123

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DForwardingServerCallListenerTest.java53 public void onMessage() { in onMessage() method in ForwardingServerCallListenerTest
54 forwarder.onMessage(12345); in onMessage()
56 verify(serverCallListener).onMessage(12345); in onMessage()
DContextsTest.java60 @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()
DServerInterceptorsTest.java318 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/
DServerCallsTest.java123 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 …]
DClientCallsTest.java102 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/
DClientInterceptorTest.cs191 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/
DRouteGuideClientTest.java131 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/core/src/main/java/io/grpc/
DForwardingServerCallListener.java32 public void onMessage(ReqT message) { in onMessage() method in ForwardingServerCallListener
33 delegate().onMessage(message); in onMessage()
DForwardingClientCallListener.java32 public void onMessage(RespT message) { in onMessage() method in ForwardingClientCallListener
33 delegate().onMessage(message); in onMessage()
DContexts.java73 public void onMessage(ReqT message) { in onMessage() method in Contexts.ContextualizedServerCallListener
76 super.onMessage(message); in onMessage()
DClientInterceptors.java115 public void onMessage(WRespT wMessage) { in wrapClientInterceptor()
118 responseListener.onMessage(message); in wrapClientInterceptor()
/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DUtilServerInterceptorsTest.java84 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/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java153 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/examples/src/main/java/io/grpc/examples/routeguide/
DRouteGuideClient.java78 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/perfetto/ui/src/controller/
Dadb_interfaces.ts29 onMessage(message: AdbMsg): void; method
64 onMessage = (_: AdbMsg) => {}; property in MockAdbStream
/external/perfetto/ui/src/common/
Dwasm_engine_proxy.ts85 this.worker.onmessage = this.onMessage.bind(this);
141 onMessage(m: MessageEvent) { method in WasmEngineProxy
/external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/
DAutobahnTester.java85 @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/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/
DWebSocketReaderTest.java156 @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/test/java/com/squareup/okhttp/ws/
DWebSocketRecorder.java36 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()
DWebSocketCallTest.java222 @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/
DSafeMethodCachingInterceptor.java228 public void onMessage(RespT message) {
233 super.onMessage(message);
275 interceptedListener.onMessage((RespT) cachedResponse.response);
/external/dagger2/java/dagger/grpc/server/
DProxyServerCallHandler.java126 public void onMessage(InputStream message) { in onMessage() method in ProxyServerCallHandler.ServerCallListenerAdapter
127 delegate.onMessage(delegateMethodDescriptor.parseRequest(message)); in onMessage()
/external/autotest/client/site_tests/policy_DisableScreenshots/Screenshooter/
Dcontent.js1 chrome.runtime.onMessage.addListener((msg, sender, sendResponse) => {
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/
DWebSocketListener.java55 void onMessage(ResponseBody message) throws IOException; in onMessage() method
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
DRealWebSocket.java61 @Override public void onMessage(ResponseBody message) throws IOException { in RealWebSocket()
62 listener.onMessage(message); in RealWebSocket()

123