class GrpcKit::Interceptors::Client::ClientStreamer

Private Instance Methods

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

@param interceptor [GrpcKit::Grpc::ClientInterceptor] @param call [GrpcKit::Calls::Client::ClientStreamer] @param metadata [Hash<String,String>]

# File lib/grpc_kit/interceptors/client_client_streamer.rb, line 13
def invoke(interceptor, call, metadata)
  # We don't need a `:requests` parameter but,
  # it shuoldn't remove from paramters due to having a compatibility of grpc gem.
  interceptor.client_streamer(requests: nil, call: call, method: call.method, metadata: metadata) do |new_call = nil|
    yield(new_call || call, metadata)
  end
end