Sha256: 6328fcc90ebb5dbe0e65c096c2bea355ed6328851035fe58a0562f947faea75a
Contents?: true
Size: 1.03 KB
Versions: 1
Compression:
Stored size: 1.03 KB
Contents
# frozen_string_literal: true require 'grpc_kit/interceptors' module GrpcKit module Interceptors::Client class RequestResponse # @param interceptors [Array<GrpcKit::GRPC::ClientInterceptor>] def initialize(interceptors) @registry = GrpcKit::InterceptorRegistry.new(interceptors) end # @param call [GrpcKit::Calls::Client::RequestResponse] # @param metadata [Hash<String,String>] # @yieldreturn [Object] Response object server sent def intercept(request, call, metadata, &block) do_intercept(@registry.build, request, call, metadata, &block) end private def do_intercept(interceptors, request, call, metadata) if interceptors.empty? return yield end interceptor = interceptors.pop interceptor.request_response(request: request, call: call, method: call.method, metadata: metadata) do do_intercept(interceptors, request, call, metadata) do yield end end end end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
grpc_kit-0.2.0 | lib/grpc_kit/interceptors/client_request_response.rb |