(
MethodDescriptor<?, ?> method, Metadata headers, CallOptions callOptions,
ClientStreamTracer[] tracers)
| 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) { |
nothing calls this directly
no test coverage detected