Method: SlowService#a_server_streaming_rpc

Defined in:
src/ruby/spec/generic/rpc_server_spec.rb

#a_server_streaming_rpc(_, call) ⇒ Object 



79
80
81
82
83
84
 
# File 'src/ruby/spec/generic/rpc_server_spec.rb', line 79

def a_server_streaming_rpc(_, call)
  GRPC.logger.info("starting a slow #{@delay} server streaming rpc")
  sleep @delay
  @received_md << call.metadata unless call.metadata.nil?
  [EchoMsg.new, EchoMsg.new]
end