MCPcopy Create free account
hub / github.com/grpc/grpc-java / newStream

Method newStream

core/src/main/java/io/grpc/internal/GrpcUtil.java:725–735  ·  view source on GitHub ↗
(
            MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions,
            ClientStreamTracer[] tracers)

Source from the content-addressed store, hash-verified

723 }
724 return new ClientTransport() {
725 @Override
726 public ClientStream newStream(
727 MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions,
728 ClientStreamTracer[] tracers) {
729 StreamInfo info = StreamInfo.newBuilder().setCallOptions(callOptions).build();
730 ClientStreamTracer streamTracer =
731 streamTracerFactory.newClientStreamTracer(info, headers);
732 checkState(tracers[tracers.length - 1] == NOOP_TRACER, "lb tracer already assigned");
733 tracers[tracers.length - 1] = streamTracer;
734 return transport.newStream(method, headers, callOptions, tracers);
735 }
736
737 @Override
738 public void ping(PingCallback callback, Executor executor) {

Callers

nothing calls this directly

Calls 5

newBuilderMethod · 0.95
setCallOptionsMethod · 0.80
buildMethod · 0.65
newStreamMethod · 0.65
newClientStreamTracerMethod · 0.45

Tested by

no test coverage detected