Class: EchoService

Inherits:
Object
  • Object
show all
Includes:
GRPC::GenericService
Defined in:
src/ruby/spec/support/services.rb

Overview

A test service with an echo implementation.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from GRPC::GenericService

included, underscore

Constructor Details

#initialize(**kw) ⇒ EchoService

Returns a new instance of EchoService.



46
47
48
49
50
 
# File 'src/ruby/spec/support/services.rb', line 46

def initialize(**kw)
  @trailing_metadata = kw
  @received_md = []
  @on_call_started = nil
end

Instance Attribute Details

#on_call_started ⇒ Object

Returns the value of attribute on_call_started.



44
45
46
 
# File 'src/ruby/spec/support/services.rb', line 44

def on_call_started
  @on_call_started
end

#received_md ⇒ Object (readonly)

Returns the value of attribute received_md.



43
44
45
 
# File 'src/ruby/spec/support/services.rb', line 43

def received_md
  @received_md
end

Instance Method Details

#a_bidi_rpc(requests, call) ⇒ Object 



74
75
76
77
78
79
80
 
# File 'src/ruby/spec/support/services.rb', line 74

def a_bidi_rpc(requests, call)
  call.output_metadata.update(@trailing_metadata)
  requests.each do |r|
    GRPC.logger.info(r)
  end
  [EchoMsg.new, EchoMsg.new]
end

#a_client_streaming_rpc(call) ⇒ Object 



60
61
62
63
64
65
66
67
 
# File 'src/ruby/spec/support/services.rb', line 60

def a_client_streaming_rpc(call)
  # iterate through requests so call can complete
  call.output_metadata.update(@trailing_metadata)
  call.each_remote_read.each do |r|
    GRPC.logger.info(r)
  end
  EchoMsg.new
end

#a_server_streaming_rpc(_req, call) ⇒ Object 



69
70
71
72
 
# File 'src/ruby/spec/support/services.rb', line 69

def a_server_streaming_rpc(_req, call)
  call.output_metadata.update(@trailing_metadata)
  [EchoMsg.new, EchoMsg.new]
end

#an_rpc(req, call) ⇒ Object 



52
53
54
55
56
57
58
 
# File 'src/ruby/spec/support/services.rb', line 52

def an_rpc(req, call)
  GRPC.logger.info('echo service received a request')
  on_call_started&.call(call)
  call.output_metadata.update(@trailing_metadata)
  @received_md << call.metadata unless call.metadata.nil?
  req
end