class GrpcKit::Rpcs::Server::ClientStreamer
Public Instance Methods
invoke(stream, metadata: {})
click to toggle source
@param stream [GrpcKit::Stream::ServerStream] @param metadata [Hash<String, String>] @return [void]
# File lib/grpc_kit/rpcs/server_client_streamer.rb, line 12 def invoke(stream, metadata: {}) call = GrpcKit::Calls::Server::ClientStreamer.new( metadata: metadata, config: @config, stream: stream, ) if @config.interceptor @config.interceptor.intercept(call) do |c| resp = @handler.send(@config.ruby_style_method_name, c) c.send_msg(resp) end else resp = @handler.send(@config.ruby_style_method_name, call) call.send_msg(resp) end end