class GRPC::RequestStream(T)

• GRPC::RequestStream(T)
• Reference
• Object

Overview

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.

Included Modules

• Enumerable(T)

Defined in:

grpc/service_handler.cr

Constructors

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

Instance Method Summary

• #each(& : T -> ) : Nil

  Must yield this collection's elements to the block.

Constructor Detail

Instance Method Detail