Class: Evidence::PipeStream

Inherits:

Object

• Object
• Evidence::PipeStream

Includes:

Stream

Defined in:

lib/evidence/stream.rb

Instance Method Summary

• #each(&output) ⇒ Object
• #eos? ⇒ Boolean
• #initialize(upstream, process) ⇒ PipeStream constructor

  A new instance of PipeStream.

Methods included from Stream

#|

Constructor Details

#initialize(upstream, process) ⇒ PipeStream

Returns a new instance of PipeStream.

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

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

Instance Method Details

#each(&output) ⇒ Object

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

def each(&output)
  @upstream.each(&@process[output])
end

#eos? ⇒ Boolean

Returns:

• (Boolean)

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

def eos?
  @upstream.eos?
end