Stream promises using effection

promises

import { createStream } from 'effection';

// create an effection stream out of an array of promises
// https://frontside.com/effection/docs/guides/collections
export function producer(promises) {
  return createStream(publish => {
    for (let promise of promises) {
      promise.then(publish);
    }
  });
}

//consume a stream of promises using the producer function
export function* consumer(promises) {
  yield producer(promises).forEach(function*(value) {
    // do something with value
  })
}