Class: Gritz::Controller::Stream

Inherits:
Object
  • Object
show all
Defined in:
/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/controller.rb

Instance Method Summary collapse

Constructor Details

#initialize(call, context) ⇒ Stream

Returns a new instance of Stream.



144
145
146
147
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/controller.rb', line 144

def initialize(call, context)
  @call = call
  @context = context
end

Instance Method Details

#write(message) ⇒ Object

Raises:

  • (TypeError) 


149
150
151
152
153
154
155
156
157
 
# File '/home/runner/work/gritz/gritz/sources/gritz-core/lib/gritz/controller.rb', line 149

def write(message)
  raise TypeError, "RPC method does not stream responses" unless @context.method.server_streaming?

  @context.check_deadline!
  @context.check_cancelled!
  @context.validate_response!(message)
  @call.write(message)
  @context.record_sent(message)
end