class

GRPC::Transport::PendingStream

Inherits Reference < Object

PendingStream holds state for an in-flight client server-streaming RPC.

Constructors

Instance methods

add_header(key : String, value : String) : Nil
Source
begin_header_block
Source
cancel

cancel sends an HTTP/2 RST_STREAM with error code CANCEL and closes the message channel so waiting iterators unblock.

Source
cancel_proc
Source
cancel_proc=(cancel_proc : -> Nil | Nil)
Source
cancelled?
Source
close_send

close_send signals the end of the client request stream for live bidi.

Source
finish
Source
grpc_headers
Source
grpc_status
Source
grpc_trailers

grpc_trailers returns the raw trailer hash received from the server.

Source
headers
Source
live_send_buf
Source
live_send_buf=(live_send_buf : LiveSendBuffer | Nil)
Source
messages
Source
messages=(messages : ::Channel(Bytes | Nil))
Source
outbound_compression=(outbound_compression : Bool)
Source
outbound_compression?
Source
receive_data(chunk : Bytes) : Nil
Source
send_buf
Source
send_buf=(send_buf : SendBuffer | Nil)
Source
send_outgoing(framed_bytes : Bytes) : Nil

send_outgoing enqueues a pre-framed gRPC message for live bidi streaming and signals nghttp2 to resume data transmission.

Source
send_resume_proc
Source
send_resume_proc=(send_resume_proc : -> Nil | Nil)
Source
trailers
Source
transport_error=(status : Status) : Nil
Source