class GrpcKit::Interceptors::Client::ServerStreamer
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::ServerStreamer] @param metadata [Hash<String,String>]
# File lib/grpc_kit/interceptors/client_server_streamer.rb, line 13 def invoke(interceptor, call, metadata) # 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, metadata: metadata) do |new_call = nil| yield(new_call || call, metadata) end end