Class: Griffin::Interceptors::CallStream

Inherits:

GrpcKit::Call

• Object
• GrpcKit::Call
• Griffin::Interceptors::CallStream

Extended by:

Forwardable

Includes:

Enumerable

Defined in:

lib/griffin/interceptors/call_stream.rb

Direct Known Subclasses

Server::PayloadStreamer

Instance Method Summary

• #each ⇒ Object
• #initialize(inner) ⇒ CallStream constructor

  A new instance of CallStream.

• #method_missing(name, *args, &block) ⇒ Object

Constructor Details

#initialize(inner) ⇒ CallStream

Returns a new instance of CallStream.

# File 'lib/griffin/interceptors/call_stream.rb', line 14

def initialize(inner)
  @inner = inner
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(name, *args, &block) ⇒ Object

# File 'lib/griffin/interceptors/call_stream.rb', line 22

def method_missing(name, *args, &block)
  @inner.public_send(name, *args, &block)
end

Instance Method Details

#each ⇒ Object

# File 'lib/griffin/interceptors/call_stream.rb', line 18

def each
  loop { yield(recv) }
end