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 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:) { || ... } click to toggle source
# 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:) { || ... } click to toggle source
# 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:) { || ... } click to toggle source
# 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