Open tshemsedinov opened 6 years ago
Make flow() compatible with collector(), implement methods:
flow()
collector()
collect(key, error, value)
pick(key, value)
fail(key, error)
take(key, fn, ...args)
timeout(msec)
done(callback)
cancel(err)
then(fulfilled, rejected)
Make
flow()compatible withcollector(), implement methods:collect(key, error, value)pick(key, value)fail(key, error)take(key, fn, ...args)timeout(msec)done(callback)cancel(err)then(fulfilled, rejected)