class TestServerInterceptor
For testing server interceptors
Public Instance Methods
bidi_streamer(requests:, call:, method:) { || ... }
click to toggle source
# File src/ruby/spec/support/services.rb, line 104 def bidi_streamer(requests:, call:, method:) requests.each do |r| GRPC.logger.info("Bidi request: #{r}") end GRPC.logger.info("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:) { || ... }
click to toggle source
# File src/ruby/spec/support/services.rb, line 86 def client_streamer(call:, method:) call.output_metadata[:interc] = 'from_client_streamer' call.each_remote_read.each do |r| GRPC.logger.info("In interceptor: #{r}") end GRPC.logger.info( "Received client streamer call at method #{method} for call #{call}" ) yield end
request_response(request:, call:, method:) { || ... }
click to toggle source
# File src/ruby/spec/support/services.rb, line 78 def request_response(request:, call:, method:) GRPC.logger.info("Received request/response call at method #{method}" \ " with request #{request} for call #{call}") call.output_metadata[:interc] = 'from_request_response' GRPC.logger.info("[GRPC::Ok] (#{method.owner.name}.#{method.name})") yield end
server_streamer(request:, call:, method:) { || ... }
click to toggle source
# File src/ruby/spec/support/services.rb, line 97 def server_streamer(request:, call:, method:) GRPC.logger.info("Received server streamer call at method #{method} with request" \ " #{request} for call #{call}") call.output_metadata[:interc] = 'from_server_streamer' yield end