Sha256: ec50afbcfd4ea27fe822eaac41eef98528f21b55a82eb14e4595870faaaccea4

Contents?: true

Size: 383 Bytes

Versions: 7

Compression:

Stored size: 383 Bytes

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(request, call, method) do
        yield
      end
    end

    def call(*)
      raise NotImplementedError
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
anycable-0.6.5 lib/anycable/middleware.rb
anycable-0.6.4 lib/anycable/middleware.rb
anycable-0.6.3 lib/anycable/middleware.rb
anycable-0.6.2 lib/anycable/middleware.rb
anycable-0.6.1 lib/anycable/middleware.rb
anycable-0.6.0 lib/anycable/middleware.rb
anycable-0.6.0.rc1 lib/anycable/middleware.rb