Protocol::GRPCSourceProtocolGRPCStreaming

class Streaming

Wrapper class to mark a message type as streamed. Used with the stream() helper method in RPC definitions.

Definitions

def initialize(message_class)

Initialize a new Streaming wrapper.

Signature

parameter message_class Class

The message class being wrapped

Implementation

def initialize(message_class)
	@message_class = message_class
end

attr :message_class

Signature

attribute Class

The wrapped message class