class GrpcKit::Interceptors::Server::ServerStreamer

Public Instance Methods

invoke(interceptor, call) { |new_call || call| ... } click to toggle source

@param interceptor [GrpcKit::Grpc::ServerInterceptor] @param call [GrpcKit::Calls::Client::ServerStreamer]

# 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