Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/grpc/grpc-java
/ functions
Functions
22,628 in github.com/grpc/grpc-java
⨍
Functions
22,628
◇
Types & classes
3,835
Method
request
(int numMessages)
alts/src/test/java/io/grpc/alts/AuthorizationUtilTest.java:74
Method
request
(int numMessages)
alts/src/main/java/io/grpc/alts/FailingClientCall.java:37
Method
request
(int numMessages)
api/src/testFixtures/java/io/grpc/NoopServerCall.java:34
Method
request
(int numMessages)
api/src/testFixtures/java/io/grpc/NoopClientCall.java:37
Method
request
(int numMessages)
api/src/test/java/io/grpc/ClientInterceptorsTest.java:443
Method
request
(int numMessages)
api/src/main/java/io/grpc/ClientInterceptors.java:169
Method
request
Requests up to the given number of messages from the call to be delivered to {@link Listener#onMessage(Object)}. Once {@code numMessages} have been de
api/src/main/java/io/grpc/ServerCall.java:117
Method
request
Requests up to the given number of messages from the call to be delivered to {@link Listener#onMessage(Object)}. No additional messages will be delive
api/src/main/java/io/grpc/ClientCall.java:212
Method
request
(int numMessages)
api/src/main/java/io/grpc/PartialForwardingClientCall.java:32
Method
request
(int numMessages)
api/src/main/java/io/grpc/PartialForwardingServerCall.java:31
Method
request
(int numMessages)
binder/src/main/java/io/grpc/binder/internal/SingleMessageClientStream.java:79
Method
request
(int numMessages)
binder/src/main/java/io/grpc/binder/internal/SingleMessageServerStream.java:80
Method
request
(int numMessages)
binder/src/main/java/io/grpc/binder/internal/MultiMessageServerStream.java:77
Method
request
(int numMessages)
binder/src/main/java/io/grpc/binder/internal/MultiMessageClientStream.java:81
Method
request
(int numMessages)
stub/src/test/java/io/grpc/stub/ClientCallsTest.java:437
Method
request
(int numMessages)
stub/src/test/java/io/grpc/stub/ServerCallsTest.java:690
Method
request
(int count)
stub/src/main/java/io/grpc/stub/ClientCalls.java:513
Method
request
Requests the peer to produce {@code count} more messages to be delivered to the 'inbound' {@link StreamObserver}. <p>This method is safe to call from
stub/src/main/java/io/grpc/stub/CallStreamObserver.java:126
Method
request
Requests the peer to produce {@code count} more messages to be delivered to the 'inbound' {@link StreamObserver}. <p>This method is safe to call from
stub/src/main/java/io/grpc/stub/ClientCallStreamObserver.java:102
Method
request
Requests the peer to produce {@code count} more messages to be delivered to the 'inbound' {@link StreamObserver}. <p>This method is safe to call from
stub/src/main/java/io/grpc/stub/ServerCallStreamObserver.java:157
Method
request
(int count)
stub/src/main/java/io/grpc/stub/ServerCalls.java:445
Method
request
(int numMessages)
xds/src/main/java/io/grpc/xds/GcpAuthenticationFilter.java:249
Method
request
(int numMessages)
xds/src/main/java/io/grpc/xds/FaultFilter.java:487
Method
requestConnection
()
rls/src/test/java/io/grpc/rls/RlsLoadBalancerTest.java:905
Method
requestConnection
()
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:419
Method
requestConnection
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:640
Method
requestConnection
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:3187
Method
requestConnection
()
core/src/test/java/io/grpc/internal/AutoConfiguredLoadBalancerFactoryTest.java:749
Method
requestConnection
()
core/src/main/java/io/grpc/internal/AutoConfiguredLoadBalancerFactory.java:135
Method
requestConnection
()
grpclb/src/main/java/io/grpc/grpclb/GrpclbLoadBalancer.java:122
Method
requestConnection
()
services/src/test/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactoryTest.java:1319
Method
requestConnection
()
api/src/test/java/io/grpc/LoadBalancerTest.java:379
Method
requestConnection
The channel asks the LoadBalancer to establish connections now (if applicable) so that the upcoming RPC may then just pick a ready connection without
api/src/main/java/io/grpc/LoadBalancer.java:444
Method
requestConnection
()
examples/src/main/java/io/grpc/examples/customloadbalance/ShufflingPickFirstLoadBalancer.java:151
Method
requestConnection
()
util/src/main/java/io/grpc/util/ForwardingLoadBalancer.java:62
Method
requestConnection
()
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:174
Method
requestConnectionForwardedToLatestPolicies
()
util/src/test/java/io/grpc/util/GracefulSwitchLoadBalancerTest.java:292
Method
requestConnectionPicker
()
core/src/test/java/io/grpc/internal/PickFirstLoadBalancerTest.java:302
Method
requestConnectionPicker
()
core/src/test/java/io/grpc/internal/PickFirstLeafLoadBalancerTest.java:419
Method
requestInvokesMessagesAvailableOnListener
()
core/src/test/java/io/grpc/internal/ApplicationThreadDeframerTest.java:56
Method
requestPasswordAuthentication
( String host, InetAddress addr, int port, String protocol, String prompt, String scheme)
core/src/main/java/io/grpc/internal/ProxyDetectorImpl.java:126
Method
requestRealisticBindServiceBehavior
()
binder/src/test/java/io/grpc/binder/internal/RobolectricBinderTransportTest.java:175
Method
requestTest
()
core/src/test/java/io/grpc/internal/ForwardingClientStreamTest.java:59
Method
requestWithNoCacheAndOnlyIfCached_fails
()
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:212
Method
requestWithNoCacheOptionSkipsCache
()
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:159
Method
requestWithOnlyIfCachedOption_unavailableIfNotInCache
()
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:178
Method
requestWithOnlyIfCachedOption_usesCache
()
examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptorTest.java:196
Method
request_beforeStart
()
core/src/test/java/io/grpc/internal/DelayedStreamTest.java:104
Method
requestingTooManyBytesStillReturnsEndOfBlock
()
core/src/test/java/io/grpc/internal/GzipInflatingBufferTest.java:184
Method
requireClientAuth_noClientCert_expectException
()
xds/src/test/java/io/grpc/xds/XdsSecurityClientServerTest.java:495
Method
requireFakeFeature
Requires {@link Feature#FAKE} to be understood. For use in testing consumers of this credential.
api/src/main/java/io/grpc/TlsChannelCredentials.java:238
Method
reschedules
()
core/src/test/java/io/grpc/internal/ReschedulerTest.java:80
Method
reschedulesShortDelay
()
core/src/test/java/io/grpc/internal/ReschedulerTest.java:99
Method
reservedHeadersStripped
()
cronet/src/test/java/io/grpc/cronet/CronetClientStreamTest.java:771
Method
reset
()
core/src/test/java/io/grpc/internal/BackoffPolicyRetrySchedulerTest.java:75
Method
reset
()
core/src/main/java/io/grpc/internal/CompositeReadableBuffer.java:208
Method
reset
()
core/src/main/java/io/grpc/internal/ReadableBuffers.java:214
Method
reset
()
core/src/main/java/io/grpc/internal/ReadableBuffers.java:304
Method
reset
()
core/src/main/java/io/grpc/internal/ReadableBuffers.java:369
Method
reset
Resets the {@link BackoffPolicyRetryScheduler} and cancels any pending retry task. The policy will be cleared thus also resetting any state associated
core/src/main/java/io/grpc/internal/BackoffPolicyRetryScheduler.java:73
Method
reset
()
core/src/main/java/io/grpc/internal/ForwardingReadableBuffer.java:110
Method
reset
()
core/src/main/java/io/grpc/internal/AbstractReadableBuffer.java:58
Method
reset
(long time)
api/src/test/java/io/grpc/DeadlineTest.java:336
Method
reset
()
okhttp/third_party/okhttp/test/java/io/grpc/okhttp/internal/framed/HpackTest.java:50
Method
reset
()
binder/src/main/java/io/grpc/binder/internal/ParcelableInputStream.java:150
Method
reset
()
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:654
Method
reset
()
netty/src/main/java/io/grpc/netty/NettyReadableBuffer.java:107
Method
resetCallCounters
Resets the call counters for all the trackers in the map.
util/src/main/java/io/grpc/util/OutlierDetectionLoadBalancer.java:700
Method
resetConnectBackoff
Immediately attempt to reconnect if the current state is TRANSIENT_FAILURE. Otherwise, this method has no effect.
core/src/main/java/io/grpc/internal/InternalSubchannel.java:336
Method
resetConnectBackoff
()
core/src/main/java/io/grpc/internal/ForwardingManagedChannel.java:81
Method
resetConnectBackoff
()
android/src/main/java/io/grpc/android/AndroidChannelBuilder.java:298
Method
resetConnectBackoff_noOpWhenChannelShutdown
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2895
Method
resetConnectBackoff_noOpWhenNameResolverNotStarted
()
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java:2910
Method
resetConnectBackoff_noopOnIdleTransport
()
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:1301
Method
resetCounters_resetsPingTime
()
core/src/test/java/io/grpc/internal/KeepAliveEnforcerTest.java:183
Method
resetCounters_resetsStrikes
()
core/src/test/java/io/grpc/internal/KeepAliveEnforcerTest.java:168
Method
resetOnReadyThreshold
()
core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java:523
Method
resetUnmarkedShouldThrow
()
core/src/test/java/io/grpc/internal/CompositeReadableBufferTest.java:157
Method
reset_streamListenerRpcProgress
()
okhttp/src/test/java/io/grpc/okhttp/OkHttpClientTransportTest.java:2135
Method
resize
Resizes cache. If new size is smaller than current estimated size, it will free up space by removing expired entries and removing oldest entries by LR
rls/src/main/java/io/grpc/rls/LinkedHashLruCache.java:244
Method
resizeMetricInstrumentsCapacityIncrease
()
api/src/test/java/io/grpc/MetricInstrumentRegistryTest.java:179
Method
resolutionResult_hashCode
()
api/src/test/java/io/grpc/NameResolverTest.java:183
Method
resolutionResult_toString_addressesAttributesAndConfig
()
api/src/test/java/io/grpc/NameResolverTest.java:169
Method
resolve
()
binder/src/main/java/io/grpc/binder/internal/ServiceBinding.java:270
Method
resolveAddress
(String host)
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:491
Method
resolveAddress
(String host)
core/src/main/java/io/grpc/internal/DnsNameResolver.java:598
Method
resolveAddress
(String host)
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:133
Method
resolveAll_balancerLookupFails_stillLookUpServiceConfig
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:290
Method
resolveSrv
(String host)
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:144
Method
resolveTxt
(String host)
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:139
Method
resolve_addressAndBalancersLookupFail_stillLookupServiceConfig
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:320
Method
resolve_addressFailure_stillLookUpBalancersAndServiceConfig
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:252
Method
resolve_addressFailure_stillLookUpServiceConfig
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:686
Method
resolve_addressResolutionError
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:516
Method
resolve_androidIgnoresPropertyValue
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:423
Method
resolve_androidIgnoresPropertyValueCacheForever
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:429
Method
resolve_cacheExpired
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:387
Method
resolve_cacheForever
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:319
Method
resolve_emptyResult
()
core/src/test/java/io/grpc/internal/DnsNameResolverTest.java:485
Method
resolve_emptyResult
()
grpclb/src/test/java/io/grpc/grpclb/GrpclbNameResolverTest.java:130
← previous
next →
18,501–18,600 of 22,628, ranked by callers