Class: GrpcKit::Interceptors::Server::ServerStreamer

Inherits:
Streaming
  • Object
show all
Defined in:
lib/grpc_kit/interceptors/server_server_streamer.rb

Instance Method Summary collapse

Methods inherited from Streaming

#initialize, #intercept

Constructor Details

This class inherits a constructor from GrpcKit::Interceptors::Server::Streaming

Instance Method Details

#invoke(interceptor, call) ⇒ Object



10
11
12
13
14
15
16
# File 'lib/grpc_kit/interceptors/server_server_streamer.rb', line 10

def invoke(interceptor, call)
  # We don't need a `:request` parameter but,
  # it shuoldn't remove from paramters due to having a compatibility of grpc gem.
  interceptor.server_streamer(request: nil, call: call, method: call.method) do |new_call = nil|
    yield(new_call || call)
  end
end