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_classClass 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