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