class

GRPC::RequestStream(T)

Inherits Enumerable < Reference < Object

RequestStream(T) is the server-side handle for an inbound request stream. It exposes an Enumerable(T) interface over messages arriving from the client. The channel is closed (nil sentinel) when the client sends END_STREAM.

Constructors

new(ch : ::Channel(Bytes | Nil), marshaller : Marshaller(T) = ProtoMarshaller(T).new)

Source

Instance methods

each

Must yield this collection's elements to the block.

Source