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 |
|
|---|---|
| Name | Description |
RequestT |
|
ResponseT |
|
Constructors
TracedClientStreamingCallable(ClientStreamingCallable<RequestT,ResponseT> innerCallable, ApiTracerFactory tracerFactory, SpanName spanName)
public TracedClientStreamingCallable(ClientStreamingCallable<RequestT,ResponseT> innerCallable, ApiTracerFactory tracerFactory, SpanName spanName)| Parameters | |
|---|---|
| Name | Description |
innerCallable |
ClientStreamingCallable<RequestT,ResponseT> |
tracerFactory |
ApiTracerFactory |
spanName |
SpanName |
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 | |
|---|---|
| Name | Description |
responseObserver |
ApiStreamObserver<ResponseT> |
context |
ApiCallContext |
| Returns | |
|---|---|
| Type | Description |
ApiStreamObserver<RequestT> |
|