class GrpcKit::Rpcs::Server::ServerStreamer
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_server_streamer.rb, line 12 def invoke(stream, metadata: {}) call = GrpcKit::Calls::Server::ServerStreamer.new( metadata: metadata, config: @config, stream: stream, ) if @config.interceptor @config.interceptor.intercept(call) do |c| request = c.recv @handler.send(@config.ruby_style_method_name, request, c) end else request = call.recv @handler.send(@config.ruby_style_method_name, request, call) end stream.send_status end