Class TracedClientStreamingCallable<RequestT,ResponseT> (2.12.2) 

public class TracedClientStreamingCallable<RequestT,ResponseT> extends ClientStreamingCallable<RequestT,ResponseT>

A wrapper callable that will wrap a callable chain in a trace.

This can be safely called from multiple threads. However the request ApiStreamObserver can only be used from a single thread.

For internal use only.

Inheritance

java.lang.Object > ClientStreamingCallable > TracedClientStreamingCallable<RequestT,ResponseT>

Type Parameters

NameDescription
RequestT
ResponseT

Constructors

TracedClientStreamingCallable(ClientStreamingCallable<RequestT,ResponseT> innerCallable, ApiTracerFactory tracerFactory, SpanName spanName)

public TracedClientStreamingCallable(ClientStreamingCallable<RequestT,ResponseT> innerCallable, ApiTracerFactory tracerFactory, SpanName spanName)
Parameters
NameDescription
innerCallableClientStreamingCallable<RequestT,ResponseT>
tracerFactoryApiTracerFactory
spanNameSpanName

Methods

clientStreamingCall(ApiStreamObserver<ResponseT> responseObserver, ApiCallContext context)

public ApiStreamObserver<RequestT> clientStreamingCall(ApiStreamObserver<ResponseT> responseObserver, ApiCallContext context)

Conduct a client streaming call with the given ApiCallContext

Parameters
NameDescription
responseObserverApiStreamObserver<ResponseT>
contextApiCallContext
Returns
TypeDescription
ApiStreamObserver<RequestT>
Overrides