geneviv

A new take on Observables using the generator interface as a core design abstraction.

Example

import { EventStream } from 'geneviv';

// Create an event stream that will send some number values
const stream = new EventStream(observer => {
  console.log('A new listener has been attached.');

  queueMicrotask(async function() {
    // Send some values to the listener. Note that we must
    // send values in a future turn of the event loop; the
    // event stream is not yet active when the init function
    // is called.
    observer.next(1);
    observer.next(2);

    await null;

    // Signal that the stream has ended. If we've returned
    // a cancel function from init, it will now be called.
    observer.return();
  });

  return () => {
    console.log('The listener has been detached.');
  };
});

// Transform the stream and attach a listener
stream.map(value => value * 2).listen(value => {
  console.log(`Next value is: ${ value }`);
});