Class: TestServerInterceptor

Inherits:
GRPC::ServerInterceptor show all
Defined in:
src/ruby/spec/support/services.rb

Overview

For testing server interceptors

Instance Method Summary collapse

Methods inherited from GRPC::Interceptor

#initialize

Constructor Details

This class inherits a constructor from GRPC::Interceptor

Instance Method Details

#bidi_streamer(requests:, call:, method:) ⇒ Object 



97
98
99
100
101
102
103
104
105
 
# File 'src/ruby/spec/support/services.rb', line 97

def bidi_streamer(requests:, call:, method:)
  requests.each do |r|
    p "Bidi request: #{r}"
  end
  p "Received bidi streamer call at method #{method} with requests" \
    " #{requests} for call #{call}"
  call.output_metadata[:interc] = 'from_bidi_streamer'
  yield
end

#client_streamer(call:, method:) ⇒ Object 



81
82
83
84
85
86
87
88
 
# File 'src/ruby/spec/support/services.rb', line 81

def client_streamer(call:, method:)
  call.output_metadata[:interc] = 'from_client_streamer'
  call.each_remote_read.each do |r|
    p "In interceptor: #{r}"
  end
  p "Received client streamer call at method #{method} for call #{call}"
  yield
end

#request_response(request:, call:, method:) ⇒ Object 



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

def request_response(request:, call:, method:)
  p "Received request/response call at method #{method}" \
    " with request #{request} for call #{call}"
  call.output_metadata[:interc] = 'from_request_response'
  p "[GRPC::Ok] (#{method.owner.name}.#{method.name})"
  yield
end

#server_streamer(request:, call:, method:) ⇒ Object 



90
91
92
93
94
95
 
# File 'src/ruby/spec/support/services.rb', line 90

def server_streamer(request:, call:, method:)
  p "Received server streamer call at method #{method} with request" \
    " #{request} for call #{call}"
  call.output_metadata[:interc] = 'from_server_streamer'
  yield
end