GrpcServerStreamingCall

The method invoked by this call.

A map containing request metadata. This is initially empty; it can be assigned to any other map of metadata before the call is executed. It is an error to set this value after the call is executed.

A map containing response metadata. This is null until the call has executed, at which point it will be non-null if the call completed successfully. It may also be non-null in failure cases if the failure was not a problem of connectivity. For example, if the gRPC call fails with an HTTP 503 error, response metadata will be present.

Configures how long the call can take to complete before it is automatically canceled. The timeout applies to the full set of messages transmitted. For long-running streams you must configure a sufficiently long timeout.

Attempts to cancel the call. This function is safe to call concurrently with execution. When canceled, execution fails with an immediate IOException rather than waiting to complete normally.

Create a new, identical gRPC call to this one which can be enqueued or executed even if this call has already been.

Enqueues this call for execution, sends singe request, and returns a stream to receive the call's responses. Reads and writes on the returned streams are blocking.

Enqueues this call for execution, sends single request, and returns a channel to receive the call's responses. This uses the Dispatchers.IO to transmit outbound messages.

True if cancel was called.

Returns true if executeIn or executeBlocking was called. It is an error to execute a call more than once.