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
onHeaders
(Metadata headers)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:935
Method
onHeaders
(Metadata headers)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:373
Method
onHeaders
(Metadata headers)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:188
Method
onHeaders
(Metadata headers)
examples/src/main/java/io/grpc/examples/header/HeaderClientInterceptor.java:51
Method
onHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:556
Method
onHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:613
Method
onHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/ClientCalls.java:765
Method
onHeaders
(Metadata headers)
stub/src/main/java/io/grpc/stub/MetadataUtils.java:137
Method
onHeaders
(Metadata headers)
xds/src/main/java/io/grpc/xds/XdsNameResolver.java:515
Method
onHeaders
(Metadata headers)
xds/src/main/java/io/grpc/xds/GrpcXdsTransportFactory.java:213
Method
onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers)
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:441
Method
onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency,
netty/src/main/java/io/grpc/netty/NettyServerHandler.java:962
Method
onHeadersRead
(int streamId, Http2Headers headers, boolean endStream)
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:419
Method
onHeadersRead
(ChannelHandlerContext ctx, int streamId, Http2Headers headers, int streamDependency,
netty/src/main/java/io/grpc/netty/NettyClientHandler.java:1078
Method
onInUse
(InternalSubchannel is)
core/src/test/java/io/grpc/internal/InternalSubchannelTest.java:142
Method
onInUse
(InternalSubchannel is)
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java:1816
Method
onLoadReport
(MetricReport orcaLoadReport)
interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:89
Method
onLoadReport
(MetricReport callMetricReport)
interop-testing/src/main/java/io/grpc/testing/integration/CustomBackendMetricsLoadBalancerProvider.java:135
Method
onLoadReport
(MetricReport orcaLoadReport)
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:89
Method
onLoadReport
(MetricReport orcaLoadReport)
examples/example-orca/src/main/java/io/grpc/examples/orca/CustomBackendMetricsLoadBalancerProvider.java:129
Method
onLoadReport
Copies ORCA metrics from {@link MetricReport} to {@link ClusterLocalityStats} such that they are included in the snapshot for the LRS report sent to t
xds/src/main/java/io/grpc/xds/ClusterImplLoadBalancer.java:536
Method
onLoadReport
(MetricReport report)
xds/src/main/java/io/grpc/xds/WeightedRoundRobinLoadBalancer.java:374
Method
onMessage
(Integer msg)
core/src/test/java/io/grpc/internal/DelayedClientCallTest.java:238
Method
onMessage
(String message)
core/src/test/java/io/grpc/internal/ServerImplTest.java:1256
Method
onMessage
(Void message)
core/src/test/java/io/grpc/internal/ClientCallImplTest.java:650
Method
onMessage
(final RespT message)
core/src/main/java/io/grpc/internal/DelayedClientCall.java:510
Method
onMessage
(ReqT message)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingServerInterceptor.java:203
Method
onMessage
(RespT message)
gcp-observability/src/main/java/io/grpc/gcp/observability/interceptors/InternalLoggingChannelInterceptor.java:143
Method
onMessage
(Integer message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:150
Method
onMessage
(RespT message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:315
Method
onMessage
(ReqT message)
services/src/test/java/io/grpc/protobuf/services/BinaryLogProviderTest.java:368
Method
onMessage
(final HealthCheckResponse response)
services/src/main/java/io/grpc/protobuf/services/HealthCheckingLoadBalancerFactory.java:421
Method
onMessage
(RespT message)
services/src/main/java/io/grpc/protobuf/services/BinlogHelper.java:424
Method
onMessage
(Holder message)
api/src/test/java/io/grpc/ServerInterceptorsTest.java:328
Method
onMessage
(Object messageIn)
api/src/test/java/io/grpc/ContextsTest.java:60
Method
onMessage
()
api/src/test/java/io/grpc/ForwardingServerCallListenerTest.java:55
Method
onMessage
(RespT message)
api/src/main/java/io/grpc/ForwardingClientCallListener.java:31
Method
onMessage
(WRespT wMessage)
api/src/main/java/io/grpc/ClientInterceptors.java:114
Method
onMessage
(ReqT message)
api/src/main/java/io/grpc/Contexts.java:72
Method
onMessage
A request message has been received. For streaming calls, there may be zero or more request messages. @param message a received request message.
api/src/main/java/io/grpc/ServerCall.java:66
Method
onMessage
(ReqT message)
api/src/main/java/io/grpc/ForwardingServerCallListener.java:31
Method
onMessage
A response message has been received. May be called zero or more times depending on whether the call response is empty, a single message or a stream o
api/src/main/java/io/grpc/ClientCall.java:132
Method
onMessage
(WReqT message)
api/src/main/java/io/grpc/ServerInterceptors.java:321
Method
onMessage
(final ReqT message)
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:292
Method
onMessage
(ReqT request)
interop-testing/src/test/java/io/grpc/testing/integration/OpenTelemetryContextPropagationTest.java:101
Method
onMessage
(final StreamingOutputCallResponse message)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:938
Method
onMessage
(RespT message)
examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/SafeMethodCachingInterceptor.java:227
Method
onMessage
(ReqT message)
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:104
Method
onMessage
(RespT message)
examples/src/main/java/io/grpc/examples/grpcproxy/GrpcProxy.java:148
Method
onMessage
(ReqT message)
binder/src/main/java/io/grpc/binder/internal/PendingAuthListener.java:79
Method
onMessage
(ByteBuf message)
benchmarks/src/jmh/java/io/grpc/benchmarks/netty/AbstractBenchmark.java:284
Method
onMessage
(ByteBuf message)
benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadServer.java:205
Method
onMessage
(ByteBuf message)
benchmarks/src/main/java/io/grpc/benchmarks/driver/LoadClient.java:514
Method
onMessage
(Void message)
util/src/test/java/io/grpc/util/UtilServerInterceptorsTest.java:83
Method
onMessage
(ReqT message)
util/src/main/java/io/grpc/util/TransmitStatusRuntimeExceptionInterceptor.java:62
Method
onMessage
(Integer message)
opentelemetry/src/test/java/io/grpc/opentelemetry/OpenTelemetryTracingModuleTest.java:694
Method
onMessage
(ReqT message)
opentelemetry/src/main/java/io/grpc/opentelemetry/OpenTelemetryTracingModule.java:365
Method
onMessage
(Integer message)
stub/src/test/java/io/grpc/stub/ServerCallsTest.java:629
Method
onMessage
(RespT value)
stub/src/main/java/io/grpc/stub/BlockingClientCall.java:329
Method
onMessage
(RespT message)
stub/src/main/java/io/grpc/stub/ClientCalls.java:560
Method
onMessage
(RespT value)
stub/src/main/java/io/grpc/stub/ClientCalls.java:617
Method
onMessage
(T value)
stub/src/main/java/io/grpc/stub/ClientCalls.java:769
Method
onMessage
(ReqT request)
stub/src/main/java/io/grpc/stub/ServerCalls.java:153
Method
onMessage
(ReqT request)
stub/src/main/java/io/grpc/stub/ServerCalls.java:260
Method
onMessage
(T message)
xds/src/main/java/io/grpc/xds/GrpcXdsTransportFactory.java:216
Method
onMessage
(final OrcaLoadReport response)
xds/src/main/java/io/grpc/xds/orca/OrcaOobUtil.java:459
Method
onNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AProtocolNegotiatorFactoryTest.java:218
Method
onNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/S2AStubTest.java:269
Method
onNext
(SessionResp resp)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeS2AServerTest.java:98
Method
onNext
(SessionReq sessionReq)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeWriter.java:180
Method
onNext
(SessionReq req)
s2a/src/test/java/io/grpc/s2a/internal/handshaker/FakeS2AServer.java:42
Method
onNext
Places a {@code SessionResp} message in the {@code responses} queue, or an {@code IOException} if reading is complete. @param resp the {@code Session
s2a/src/main/java/io/grpc/s2a/internal/handshaker/S2AStub.java:183
Method
onNext
(io.grpc.lookup.v1.RouteLookupResponse value)
rls/src/main/java/io/grpc/rls/CachingRlsLbClient.java:346
Method
onNext
(final LoadBalanceResponse response)
grpclb/src/main/java/io/grpc/grpclb/GrpclbState.java:661
Method
onNext
Mock writer onNext. Will respond based on the server status.
alts/src/test/java/io/grpc/alts/internal/AltsHandshakerStubTest.java:148
Method
onNext
Receive a handshaker response from the server.
alts/src/main/java/io/grpc/alts/internal/AltsHandshakerStub.java:105
Method
onNext
(HealthCheckResponse value)
services/src/test/java/io/grpc/protobuf/services/HealthStatusManagerTest.java:317
Method
onNext
(ServerReflectionResponse value)
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceV1Test.java:633
Method
onNext
(ServerReflectionResponse value)
services/src/test/java/io/grpc/protobuf/services/ProtoReflectionServiceTest.java:633
Method
onNext
(ServerReflectionRequest request)
services/src/main/java/io/grpc/protobuf/services/ProtoReflectionServiceV1.java:163
Method
onNext
(StreamingOutputCallResponse value)
interop-testing/src/test/java/io/grpc/testing/integration/NettyFlowControlTest.java:204
Method
onNext
(StreamingInputCallRequest value)
interop-testing/src/test/java/io/grpc/testing/integration/MoreInProcessTest.java:90
Method
onNext
(Messages.SimpleResponse value)
interop-testing/src/test/java/io/grpc/testing/integration/CascadingTest.java:311
Method
onNext
(StreamingOutputCallResponse response)
interop-testing/src/test/java/io/grpc/testing/integration/ConcurrencyTest.java:87
Method
onNext
(SimpleResponse value)
interop-testing/src/main/java/io/grpc/testing/integration/Http2Client.java:284
Method
onNext
(StreamingInputCallRequest message)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java:182
Method
onNext
(StreamingOutputCallResponse response)
interop-testing/src/main/java/io/grpc/testing/integration/AbstractInteropTest.java:756
Method
onNext
(HandshakerReq value)
interop-testing/src/main/java/io/grpc/testing/integration/AltsHandshakerTestService.java:53
Method
onNext
(EmptyProtos.Empty response)
interop-testing/src/main/java/io/grpc/testing/integration/XdsTestClient.java:400
Method
onNext
(StreamingOutputCallResponse value)
interop-testing/src/main/java/io/grpc/testing/integration/TestServiceClient.java:987
Method
onNext
(RouteSummary summary)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:284
Method
onNext
(RouteNote note)
examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/RouteGuideActivity.java:372
Method
onNext
(Feature value)
examples/src/test/java/io/grpc/examples/routeguide/RouteGuideServerTest.java:142
Method
onNext
(Point value)
examples/src/test/java/io/grpc/examples/routeguide/RouteGuideClientTest.java:269
Method
onNext
(EchoRequest request)
examples/src/main/java/io/grpc/examples/multiplex/EchoService.java:62
Method
onNext
(EchoResponse response)
examples/src/main/java/io/grpc/examples/multiplex/SharingClient.java:100
Method
onNext
(HelloRequest request)
examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlServer.java:76
Method
onNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlClient.java:93
Method
onNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/errorhandling/DetailErrorSample.java:173
Method
onNext
(HelloReply value)
examples/src/main/java/io/grpc/examples/errorhandling/ErrorHandlingClient.java:151
← previous
next →
16,901–17,000 of 22,628, ranked by callers