class GoChanel::Pool
Attributes
proc[R]
size[R]
Public Class Methods
new(size = 1, &proc)
click to toggle source
# File lib/go_chanel/pool.rb, line 5 def initialize(size = 1, &proc) @size = size @proc = proc end
Public Instance Methods
|(pool)
click to toggle source
# File lib/go_chanel/pool.rb, line 10 def |(pool) pipe = Pipe.new pipe.pools << self pipe.pools << pool pipe end