Home
last modified time | relevance | path

Searched refs:onHalfClose (Results 1 – 16 of 16) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/util/
DUtilServerInterceptorsTest.java89 public void onHalfClose() { in statusRuntimeExceptionTransmitter()
117 getSoleMethod(intercepted).getServerCallHandler().startCall(call, headers).onHalfClose(); in statusRuntimeExceptionTransmitter()
140 public void onHalfClose() { in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
151 callDoubleSreListener.onHalfClose(); // should not trigger a close in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
161 public void onHalfClose() { in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
169 callClosedListener.onHalfClose(); // should not trigger a close in statusRuntimeExceptionTransmitterIgnoresClosedCalls()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPartialForwardingServerCallListener.java34 public void onHalfClose() { in onHalfClose() method in PartialForwardingServerCallListener
35 delegate().onHalfClose(); in onHalfClose()
DContexts.java83 public void onHalfClose() { in onHalfClose() method in Contexts.ContextualizedServerCallListener
86 super.onHalfClose(); in onHalfClose()
DServerCall.java66 public void onHalfClose() {} in onHalfClose() method in ServerCall.Listener
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DContextsTest.java66 @Override public void onHalfClose() { in interceptCall_basic()
100 wrapped.onHalfClose(); in interceptCall_basic()
133 @Override public void onHalfClose() { in interceptCall_restoresIfListenerThrows()
164 wrapped.onHalfClose(); in interceptCall_restoresIfListenerThrows()
/external/dagger2/java/dagger/grpc/server/
DProxyServerCallHandler.java131 public void onHalfClose() { in onHalfClose() method in ProxyServerCallHandler.ServerCallListenerAdapter
132 delegate.onHalfClose(); in onHalfClose()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java287 callListener.onHalfClose(); in onReadyHandlerCalledForUnaryRequest()
306 listener.onHalfClose(); in clientSendsOne_errorMissingRequest_unary()
324 listener.onHalfClose(); in clientSendsOne_errorMissingRequest_serverStreaming()
349 listener.onHalfClose(); in clientSendsOne_errorTooManyRequests_unary()
370 listener.onHalfClose(); in clientSendsOne_errorTooManyRequests_serverStreaming()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java72 public void onHalfClose() { in interceptCall() method
74 super.onHalfClose(); in interceptCall()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java281 public void onHalfClose() { in setup()
313 public void onHalfClose() { in setup()
348 public void onHalfClose() { in setup()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java159 public void onHalfClose() { in onHalfClose() method in ServerCalls.UnaryServerCallHandler.UnaryServerCallListener
257 public void onHalfClose() { in onHalfClose() method in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServerCallImplTest.java351 verify(callListener).onHalfClose(); in streamListener_halfClosed()
364 verify(callListener).onHalfClose(); in streamListener_halfClosed_onlyOnce()
DServerImplTest.java538 verify(callListener).onHalfClose(); in basicExchangeHelper()
880 public void onHalfClose() { in testCallContextIsBoundInListenerCallbacks()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadServer.java214 public void onHalfClose() { in startCall() method in GenericServiceCallHandler
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallImpl.java283 listener.onHalfClose(); in halfClosed()
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinlogHelper.java580 public void onHalfClose() {
585 super.onHalfClose();
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinlogHelperTest.java1443 capturedListener.onHalfClose(); in serverInterceptor()
1449 verify(mockListener).onHalfClose(); in serverInterceptor()