Class TracedClientStreamingCallable<RequestT,ResponseT> (2.33.0)

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>

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

Parameters
Name	Description
`innerCallable`	`ClientStreamingCallable<RequestT,ResponseT>`
`tracerFactory`	`ApiTracerFactory`
`spanName`	`SpanName`

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

Conduct a client streaming call with the given ApiCallContext

Parameters
Name	Description
`responseObserver`	`ApiStreamObserver<ResponseT>`
`context`	`ApiCallContext`

Returns
Type	Description
`ApiStreamObserver<RequestT>`

Overrides