class GRPC::Transport::PendingStream

• GRPC::Transport::PendingStream
• Reference
• Object

Overview

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

Defined in:

grpc/transport/http2_client_connection.cr

Constructors

• .new

Instance Method Summary

• #add_header(key : String, value : String) : Nil
• #begin_header_block : Nil
• #cancel : Nil

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

• #cancel_proc : -> Nil | Nil
• #cancel_proc=(cancel_proc : -> Nil | Nil)
• #cancelled? : Bool
• #close_send : Nil

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

• #finish : Nil
• #grpc_headers : Metadata
• #grpc_status : Status
• #grpc_trailers : Metadata

  grpc_trailers returns the raw trailer hash received from the server.

• #headers : Metadata
• #live_send_buf : LiveSendBuffer | Nil
• #live_send_buf=(live_send_buf : LiveSendBuffer | Nil)
• #messages : ::Channel(Bytes | Nil)
• #messages=(messages : ::Channel(Bytes | Nil))
• #receive_data(chunk : Bytes) : Nil
• #send_buf : SendBuffer | Nil
• #send_buf=(send_buf : SendBuffer | Nil)
• #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.

• #send_resume_proc : -> Nil | Nil
• #send_resume_proc=(send_resume_proc : -> Nil | Nil)
• #trailers : Metadata
• #transport_error=(status : Status) : Nil

Constructor Detail

Instance Method Detail