class

GRPC::ResponseStream(T)

Inherits Reference < Object

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

Constructors

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

Instance methods

send(message : T) : Nil

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

Source