class GrpcKit::Calls::Server::ServerStreamer
Attributes
outgoing_initial_metadata[R]
outgoing_trailing_metadata[R]
Public Class Methods
new(**)
click to toggle source
Calls superclass method
GrpcKit::Call::new
# File lib/grpc_kit/calls/server_server_streamer.rb, line 12 def initialize(**) super @outgoing_initial_metadata = {} @outgoing_trailing_metadata = {} end
Public Instance Methods
recv()
click to toggle source
@return [Object] response object
# File lib/grpc_kit/calls/server_server_streamer.rb, line 32 def recv @stream.recv_msg(@codec, last: true, limit_size: @config.max_receive_message_size) end
send_msg(data)
click to toggle source
@param data [Object] request message @return [void]
# File lib/grpc_kit/calls/server_server_streamer.rb, line 21 def send_msg(data) @stream.send_msg( data, @codec, initial_metadata: @outgoing_initial_metadata, trailing_metadata: @outgoing_trailing_metadata, limit_size: @config.max_send_message_size, ) end