Class: Dataflow::Port::Stream

Inherits:
Object
  • Object
show all
Includes:
Dataflow, Enumerable
Defined in:
lib/port.rb

Instance Method Summary collapse

Instance Method Details

#each ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/port.rb', line 17

def each
  s = self
  loop do
    yield s.head
    s = s.tail
  end
end

#take(num) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/port.rb', line 27

def take(num)
  result = []
  each_with_index do |x, i|
    return result if num == i
    result << x
  end
end