class GRPC::ResponseStream(T)

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

Overview

ResponseStream(T) is the public server-side handle for sending typed streaming responses. Service implementations receive this in server-streaming and bidi RPCs. The framework handles protobuf encoding internally.

Example (server streaming handler): def range(req : Numbers::Number, writer : GRPC::ResponseStream(Numbers::Number), ctx : GRPC::ServerContext) : GRPC::Status (1..req.value).each { |i| writer.send(Numbers::Number.new(i)) } GRPC::Status.ok end

Defined in:

grpc/stream.cr

Constructors

• .new(raw : RawResponseStream, marshaller : Marshaller(T) = ProtoMarshaller(T).new)

Instance Method Summary

• #send(message : T) : Nil

  send serialises message to protobuf and transmits it to the client.

Constructor Detail

Instance Method Detail