Contents

# frozen_string_literal: true

require 'grpc_kit/grpc/dsl'
require 'forwardable'

module GrpcKit
  module GRPC
    class Stream
      extend Forwardable
      delegate %i[encode decode] => :@klass

      def initialize(klass)
        @klass = klass
      end

      # FIXME: Do not use method_missing...
      def method_missing(name, *args, &block)
        @klass.send(name, *args, &block)
      end
    end
  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version	Path
grpc_kit-0.2.0	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.14	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.13	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.12	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.11	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.10	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.9	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.8	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.7	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.6	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.5	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.4	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.3	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.2	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.1	lib/grpc_kit/grpc/stream.rb
grpc_kit-0.1.0	lib/grpc_kit/grpc/stream.rb