Home
last modified time | relevance | path

Searched refs:onClose (Results 1 – 25 of 57) sorted by relevance

123

/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPartialForwardingClientCallListener.java38 public void onClose(Status status, Metadata trailers) { in onClose() method in PartialForwardingClientCallListener
39 delegate().onClose(status, trailers); in onClose()
DClientCall.java144 public void onClose(Status status, Metadata trailers) {} in onClose() method in ClientCall.Listener
/external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/
DSafeMethodCachingInterceptor.java237 public void onClose(Status status, Metadata trailers) {
241 super.onClose(
244 super.onClose(status, trailers);
277 interceptedListener.onClose(Status.OK, metadata);
/external/okhttp/okhttp-ws-tests/src/main/java/com/squareup/okhttp/ws/
DAutobahnTester.java108 @Override public void onClose(int code, String reason) { in runTest()
147 @Override public void onClose(int code, String reason) { in getTestCount()
182 @Override public void onClose(int code, String reason) { in updateReports()
/external/skia/src/xps/
DSkXPSDocument.cpp32 void onClose(SkWStream*) override;
69 void SkXPSDocument::onClose(SkWStream*) { in onClose() function in SkXPSDocument
/external/skqp/src/xps/
DSkXPSDocument.cpp32 void onClose(SkWStream*) override;
70 void SkXPSDocument::onClose(SkWStream*) { in onClose() function in SkXPSDocument
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java103 listener.onClose(status, trailers); in unaryBlockingCallSuccess()
120 listener.onClose(status, trailers); in unaryBlockingCallFailed()
161 listener.get().onClose(Status.OK, new Metadata()); in unaryFutureCallSuccess()
178 listener.get().onClose(Status.INTERNAL, trailers); in unaryFutureCallFailed()
214 listener.get().onClose(Status.OK, new Metadata()); in unaryFutureCallCancelled()
556 listener.get().onClose(Status.INTERNAL, trailers); in blockingResponseStreamFailed()
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/
DWebSocketCallTest.java230 @Override public void onClose(int code, String reason) { in awaitWebSocket()
231 listener.onClose(code, reason); in awaitWebSocket()
262 @Override public void onClose(int code, String reason) { in onClose() method in WebSocketCallTest.EmptyWebSocketListener
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DMetadataUtils.java170 public void onClose(Status status, Metadata trailers) { in onClose() method in MetadataUtils.MetadataCapturingClientInterceptor.MetadataCapturingClientCall.MetadataCapturingClientCallListener
172 super.onClose(status, trailers); in onClose()
DClientCalls.java430 public void onClose(Status status, Metadata trailers) { in onClose() method in ClientCalls.StreamObserverToCallListenerAdapter
472 public void onClose(Status status, Metadata trailers) { in onClose() method in ClientCalls.UnaryStreamToFuture
618 public void onClose(Status status, Metadata trailers) { in onClose() method in ClientCalls.BlockingResponseStream.QueuingListener
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/
DRealWebSocket.java80 @Override public void onClose(final int code, final String reason) { in RealWebSocket()
197 listener.onClose(code, reason); in peerClose()
DWebSocketReader.java58 void onClose(int code, String reason); in onClose() method
205 frameCallback.onClose(code, reason); in readControlFrame()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DClientCallImplTest.java162 verify(callListener).onClose(same(status), Matchers.isA(Metadata.class)); in statusPropagatedFromStreamToCallListener()
195 verify(callListener).onClose(statusArgumentCaptor.capture(), Matchers.isA(Metadata.class)); in exceptionInOnMessageTakesPrecedenceOverServer()
230 verify(callListener).onClose(statusArgumentCaptor.capture(), Matchers.isA(Metadata.class)); in exceptionInOnHeadersTakesPrecedenceOverServer()
265 verify(callListener).onClose(statusArgumentCaptor.capture(), Matchers.isA(Metadata.class)); in exceptionInOnReadyTakesPrecedenceOverServer()
541 public void onClose(Status status, Metadata trailers) { in callerContextPropagatedToListener()
628 public void onClose(Status status, Metadata trailers) { in contextAlreadyCancelledNotifiesImmediately()
670 verify(callListener, timeout(1000)).onClose(statusCaptor.capture(), any(Metadata.class)); in deadlineExceededBeforeCallStarted()
DManagedChannelImplTest.java307 verify(mockCallListener).onClose(statusCaptor.capture(), any(Metadata.class)); in immediateDeadlineExceeded()
496 verify(mockCallListener3).onClose(statusCaptor.capture(), any(Metadata.class)); in subtestCallsAndShutdown()
505 verify(mockCallListener).onClose(same(ManagedChannelImpl.SHUTDOWN_NOW_STATUS), in subtestCallsAndShutdown()
664 verify(mockCallListener, never()).onClose(same(Status.CANCELLED), same(trailers)); in callOptionsExecutor()
666 verify(mockCallListener).onClose(same(Status.CANCELLED), same(trailers)); in callOptionsExecutor()
755 verify(mockCallListener).onClose(same(status), any(Metadata.class)); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
939 verify(mockCallListener).onClose(same(status), any(Metadata.class)); in subtestFailRpcFromBalancer()
950 verify(mockCallListener2).onClose(same(status), any(Metadata.class)); in subtestFailRpcFromBalancer()
1037 verify(mockCallListener2).onClose(same(server2Error), any(Metadata.class)); in allServersFailedToConnect()
1217 verify(mockCallListener2).onClose(same(transportError), any(Metadata.class)); in oobchannels()
[all …]
DManagedChannelImplIdlenessTest.java223 verify(mockCallListener, never()).onClose(any(Status.class), any(Metadata.class)); in newCallRefreshesIdlenessTimer()
225 verify(mockCallListener, times(2)).onClose(any(Status.class), any(Metadata.class)); in newCallRefreshesIdlenessTimer()
355 verify(mockCallListener).onClose(same(Status.UNAVAILABLE), any(Metadata.class)); in oobTransportDoesNotAffectIdleness()
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/
DWebSocketListener.java72 void onClose(int code, String reason); in onClose() method
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DFailingClientCall.java34 listener.onClose(error, new Metadata()); in start()
/external/skqp/include/core/
DSkDocument.h71 virtual void onClose(SkWStream*) = 0;
/external/skia/include/core/
DSkDocument.h71 virtual void onClose(SkWStream*) = 0;
/external/skqp/src/core/
DSkDocument.cpp56 this->onClose(fStream); in close()
/external/skia/src/core/
DSkDocument.cpp56 this->onClose(fStream); in close()
/external/nanohttpd/websocket/src/main/java/fi/iki/elonen/samples/echo/
DDebugWebSocketServer.java79 protected void onClose(CloseCode code, String reason, boolean initiatedByRemote) { in onClose() method in DebugWebSocketServer.DebugWebSocket
/external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/
DSimpleEchoSocket.java78 public void onClose(int statusCode, String reason) { in onClose() method in SimpleEchoSocket
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCensusTracingModule.java395 public void onClose(io.grpc.Status status, Metadata trailers) { in interceptCall()
397 super.onClose(status, trailers); in interceptCall()
/external/autotest/frontend/client/src/autotest/common/ui/
DTableActionsPanel.java77 public void onClose(CloseEvent<PopupPanel> event) { in onClose() method in TableActionsPanel

123