A Pen by francesco agati.

script.livescript

lib = do
  sum: ([a,b], callback) -> callback a + b
  square: (a) -> a * a
    
  
stream = (worker) -> (message,...params) -> Bacon.from-promise worker[message](params)

stream-pool = (workers) -> 
   cnt = 0
   max = workers.length - 1
   (message,...params) -> 
     cnt := 0 if cnt > max
     worker = workers[cnt]
     console.log cnt
     cnt := cnt + 1
     Bacon.from-promise worker[message](params)
        
w = stream-pool [cw(lib) for x in [0 to 4]]
              
h= Bacon.combine-template do
  a: w(\sum,1,2)
  b: w(\sum,1,2)
  c7: w(\sum,1,2)
  c2: w(\sum,1,2)
  c3: w(\sum,1,2)
  c4: w(\sum,1,2)
  c5: w(\sum,1,2)
  c0: w(\sum,1,2)
  c1: w(\sum,1,2)
  c8: w(\sum,1,2)

h.log!


 
#worker.sum [2, 5] .then ((a) -> console.log a)

web-worker-pool-with-catiline.js-and-bacon.js.markdown

web worker pool with catiline.js and bacon.js

A Pen by francesco agati on CodePen.

License.