Class: Evidence::Stream

Inherits:

Object

• Object
• Evidence::Stream

Includes:

Enumerable

Defined in:

lib/evidence/stream.rb

Instance Method Summary

• #each(&block) ⇒ Object
• #eos? ⇒ Boolean
• #initialize(upstream, processor) ⇒ Stream constructor

  A new instance of Stream.

Constructor Details

#initialize(upstream, processor) ⇒ Stream

Returns a new instance of Stream.

# File 'lib/evidence/stream.rb', line 5

def initialize(upstream, processor)
  @upstream, @processor = upstream, processor
end

Instance Method Details

#each(&block) ⇒ Object

# File 'lib/evidence/stream.rb', line 13

def each(&block)
  @upstream.each(&@processor[block])
end

#eos? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/evidence/stream.rb', line 9

def eos?
  @upstream.eos?
end