MCPcopy Create free account

hub / github.com/grpc/grpc-java / functions

Functions22,628 in github.com/grpc/grpc-java

⨍ Functions 22,628◇ Types & classes 3,835
MethodcanCaptureInboundFlowControlForServerStreamingObserver
()
stub/src/test/java/io/grpc/stub/ClientCallsTest.java:597
MethodcanHandleEmptyAddressListFromNameResolution
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java:156
MethodcanHandleEmptyAddressListFromNameResolution
()
xds/src/main/java/io/grpc/xds/WeightedTargetLoadBalancer.java:130
MethodcanHandleEmptyAddressListFromNameResolutionForwardedToLatestPolicy
()
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:104
MethodcanProvide
()
core/src/test/java/io/grpc/internal/ExponentialBackoffPolicyTest.java:54
MethodcanUseByteBufferOnlyAllComponentsSupportUsingByteBuffer
()
core/src/test/java/io/grpc/internal/CompositeReadableBufferTest.java:241
Methodcancel
(String message, Throwable cause)
auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTest.java:202
Methodcancel
(boolean mayInterruptIfRunning)
core/src/testFixtures/java/io/grpc/internal/FakeClock.java:106
Methodcancel
(Status errorStatus)
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:144
Methodcancel
(Status reason)
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:617
Methodcancel
(boolean interrupt)
core/src/test/java/io/grpc/internal/SharedResourceHolderTest.java:287
Methodcancel
Tears down the stream, typically in the event of a timeout. This method may be called multiple times and from any thread. <p>This is a clone of {@lin
core/src/main/java/io/grpc/internal/AbstractServerStream.java:70
Methodcancel
(Status status)
core/src/main/java/io/grpc/internal/AbstractServerStream.java:147
Methodcancel
(String message, Throwable cause)
core/src/main/java/io/grpc/internal/SubchannelChannel.java:105
Methodcancel
(Status reason)
core/src/main/java/io/grpc/internal/DelayedClientTransport.java:392
Methodcancel
(Status status)
core/src/main/java/io/grpc/internal/NoopClientStream.java:60
Methodcancel
(Status reason)
core/src/main/java/io/grpc/internal/ForwardingClientStream.java:65
Methodcancel
(Status reason)
core/src/main/java/io/grpc/internal/AbstractClientStream.java:197
Methodcancel
(final Status reason)
core/src/main/java/io/grpc/internal/DelayedStream.java:315
Methodcancel
(@Nullable String message, @Nullable Throwable cause)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:891
Methodcancel
(@Nullable String message, @Nullable Throwable cause)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1141
Methodcancel
(String message, Throwable cause)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1156
Methodcancel
(boolean permanent)
core/src/main/java/io/grpc/internal/Rescheduler.java:69
Methodcancel
(Status status)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:631
Methodcancel
(Status reason)
inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java:843
Methodcancel
(String message, Throwable cause)
alts/src/main/java/io/grpc/alts/FailingClientCall.java:40
Methodcancel
(String message, Throwable cause)
gcp-observability/src/test/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptorTest.java:145
Methodcancel
(String message, Throwable cause)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:249
Methodcancel
(String message, Throwable cause)
services/src/test/java/io/grpc/protobuf/services/BinlogHelperTest.java:1123
Methodcancel
(String msg)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:417
Methodcancel
(String message, Throwable cause)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:486
Methodcancel
(String message, Throwable cause)
api/src/testFixtures/java/io/grpc/NoopClientCall.java:40
Methodcancel
(String message, Throwable cause)
api/src/test/java/io/grpc/ClientInterceptorsTest.java:450
Methodcancel
(String message, Throwable cause)
api/src/main/java/io/grpc/ClientInterceptors.java:172
Methodcancel
Prevent any further processing for this {@code ClientCall}. No further messages may be sent or will be received. The server is informed of cancellatio
api/src/main/java/io/grpc/ClientCall.java:229
Methodcancel
(@Nullable String message, @Nullable Throwable cause)
api/src/main/java/io/grpc/PartialForwardingClientCall.java:37
Methodcancel
Allows the service to cancel the remaining responses.
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:366
Methodcancel
(Status reason)
okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java:178
Methodcancel
(Status reason)
okhttp/src/main/java/io/grpc/okhttp/OkHttpServerStream.java:123
Methodcancel
(boolean mayInterruptIfRunning)
binder/src/testFixtures/java/io/grpc/binder/internal/MainThreadScheduledExecutorService.java:160
Methodcancel
(Status status)
binder/src/main/java/io/grpc/binder/internal/SingleMessageClientStream.java:114
Methodcancel
(Status status)
binder/src/main/java/io/grpc/binder/internal/SingleMessageServerStream.java:119
Methodcancel
(Status status)
binder/src/main/java/io/grpc/binder/internal/MultiMessageServerStream.java:127
Methodcancel
(Status status)
binder/src/main/java/io/grpc/binder/internal/MultiMessageClientStream.java:120
Methodcancel
(String message, Throwable cause)
benchmarks/src/jmh/java/io/grpc/benchmarks/CancellableInterceptor.java:37
Methodcancel
(String message, Throwable cause)
stub/src/test/java/io/grpc/stub/ClientCallsTest.java:385
Methodcancel
Cancel stream and stop any further writes. Note that some reads that are in flight may still happen after the cancel. @param message if not {@code n
stub/src/main/java/io/grpc/stub/BlockingClientCall.java:249
Methodcancel
(@Nullable String message, @Nullable Throwable cause)
stub/src/main/java/io/grpc/stub/ClientCalls.java:529
Methodcancel
Prevent any further processing for this {@code ClientCallStreamObserver}. No further messages will be received. The server is informed of cancellation
stub/src/main/java/io/grpc/stub/ClientCallStreamObserver.java:48
Methodcancel
(boolean mayInterruptIfRunning)
netty/src/test/java/io/grpc/netty/NettyHandlerTestBase.java:197
Methodcancel
(Status status)
netty/src/main/java/io/grpc/netty/NettyServerStream.java:130
Methodcancel
(Status status)
netty/src/main/java/io/grpc/netty/NettyClientStream.java:204
Methodcancel
(boolean mayInterruptIfRunning)
xds/src/test/java/io/grpc/xds/internal/security/certprovider/FileWatcherCertificateProviderTest.java:554
Methodcancel
(String message, Throwable cause)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:252
Methodcancel
(String message, Throwable cause)
xds/src/main/java/io/grpc/xds/FaultFilter.java:490
Methodcancel
(String msg)
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:529
Methodcancel
(Status reason)
cronet/src/main/java/io/grpc/cronet/CronetClientStream.java:236
MethodcancelBeforeAck_sendsEmptyUnsubscribe
If a watch is canceled after the initial DiscoveryRequest goes out but before any response is ACKed, the empty unsubscribe must still be sent — otherw
xds/src/test/java/io/grpc/xds/client/ControlPlaneClientTest.java:251
MethodcancelBufferedStreamShouldChangeClientStreamStatus
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:261
MethodcancelDeadlineExceededShouldSucceed
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:295
MethodcancelDestroyTask
()
core/src/test/java/io/grpc/internal/SharedResourceHolderTest.java:124
MethodcancelInOnMessageShouldInvokeStreamCancel
()
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:1020
MethodcancelPermanently
()
core/src/test/java/io/grpc/internal/ReschedulerTest.java:67
MethodcancelResourceWatcherNotRemoveUrlSubscribers
()
xds/src/test/java/io/grpc/xds/GrpcXdsClientImplTestBase.java:1180
MethodcancelReturnsFalseIfAlreadyCancelled
()
api/src/test/java/io/grpc/ContextTest.java:268
MethodcancelShouldSendCommand
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:155
MethodcancelShouldSendRstStream
()
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:482
MethodcancelShouldStillSendCommandIfStreamNotCreatedToCancelCreation
()
netty/src/test/java/io/grpc/netty/NettyClientStreamTest.java:177
MethodcancelShouldSucceed
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:283
MethodcancelStream
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:697
MethodcancelStream
()
cronet/src/test/java/io/grpc/cronet/CronetClientStreamTest.java:495
MethodcancelStreamForDeadlineExceeded
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:750
MethodcancelStreamShouldCreateAndThenFailBufferedStream
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:664
MethodcancelStreamShouldSucceed
()
netty/src/test/java/io/grpc/netty/NettyServerStreamTest.java:383
MethodcancelTest
()
core/src/test/java/io/grpc/internal/ForwardingClientStreamTest.java:91
MethodcancelThenSetCall
()
core/src/test/java/io/grpc/internal/DelayedClientCallTest.java:166
MethodcancelThenSetStream
()
core/src/test/java/io/grpc/internal/DelayedStreamTest.java:341
MethodcancelTwiceDifferentReasons
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:336
MethodcancelTwiceShouldSucceed
Although nobody is listening to an exception should it occur during cancel(), we don't want an exception to be thrown because it would negatively impa
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:323
MethodcancelWhileBufferedShouldSucceed
()
netty/src/test/java/io/grpc/netty/NettyClientHandlerTest.java:304
MethodcancelWhileDraining
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:858
MethodcancelWhileRetryStart
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:905
MethodcancelWithNotify_shouldSendHeaders
()
netty/src/test/java/io/grpc/netty/NettyServerHandlerTest.java:491
MethodcancelWithoutStart
()
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:962
MethodcancelXdsResourceWatch
( XdsResourceType<T> type, String resourceName, ResourceWatcher<T> watcher)
xds/src/test/java/io/grpc/xds/XdsServerTestHelper.java:241
MethodcancelXdsResourceWatch
(XdsResourceType<T> type, String resourceName,
xds/src/main/java/io/grpc/xds/client/XdsClientImpl.java:356
Methodcancel_beforeStart
()
core/src/test/java/io/grpc/internal/DelayedStreamTest.java:350
Methodcancel_closed
()
core/src/test/java/io/grpc/internal/RetriableStreamTest.java:552
Methodcancel_doNotAcceptOk
()
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:111
Methodcancel_failsOnNull
()
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:131
Methodcancel_notStarted
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientStreamTest.java:116
Methodcancel_notifiesOnlyOnce
()
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:140
Methodcancel_started
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientStreamTest.java:133
MethodcancellableAncestorFork
()
api/src/test/java/io/grpc/ContextTest.java:974
MethodcancellableAncestorIntegrationTest
()
api/src/test/java/io/grpc/ContextTest.java:955
MethodcancellableAncestorTest
()
api/src/test/java/io/grpc/ContextTest.java:938
MethodcancellableContextCascadesFromCancellableParent
()
api/src/test/java/io/grpc/ContextTest.java:453
MethodcancellableContextIsAttached
()
api/src/test/java/io/grpc/ContextTest.java:429
MethodcancellableContext_closeCancelsWithNullCause
()
api/src/test/java/io/grpc/ContextTest.java:981
MethodcancellationCancelsScheduledTask
()
api/src/test/java/io/grpc/ContextTest.java:728
← previousnext →10,901–11,000 of 22,628, ranked by callers