Class: Pipeline

Inherits:
Object
  • Object
show all
Defined in:
lib/socketeer/pipeline.rb

Instance Method Summary collapse

Constructor Details

#initialize(*messengers) ⇒ Pipeline

Returns a new instance of Pipeline.



4
5
6
 
# File 'lib/socketeer/pipeline.rb', line 4

def initialize *messengers
  @messengers = messengers
end

Instance Method Details

#cycle ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
 
# File 'lib/socketeer/pipeline.rb', line 7

def cycle
  @messengers.each_cons(2) do |a, b|
    a.cycle if a.respond_to? 'cycle'
    begin
      1000.times do 
        m = a.out_queue.deq true
        b.in_queue << m
      end
    rescue ThreadError
    end
  end
end