Contents

# frozen_string_literal: true

require "grpc"

module AnyCable
  # Middleware is a wrapper over gRPC interceptors
  # for request/response calls
  class Middleware < GRPC::Interceptor
    def request_response(request: nil, call: nil, method: nil)
      # Call middlewares only for AnyCable service
      return yield unless method.receiver.is_a?(AnyCable::RPCHandler)

      call(request, call, method) do
        yield
      end
    end

    def call(*)
      raise NotImplementedError
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
anycable-1.0.0.preview2	lib/anycable/middleware.rb
anycable-1.0.0.preview1	lib/anycable/middleware.rb