如何在CycleJs中实现eventemitter3互连

npm install eventemitter3

import { EventEmitter } from 'eventemitter3';

function eventEmitterDriver(sink$) {
  const emitter = new EventEmitter();

  sink$.addListener({
    next: event => {
      emitter.emit(event.type, event.payload);
    },
    error: () => {},
    complete: () => {},
  });

  return {
    select: eventName => {
      return {
        events: emitter,
        eventName,
      };
    },
  };
}

export default eventEmitterDriver;

import { run } from '@cycle/run';
import { makeDOMDriver, div, button } from '@cycle/dom';
import eventEmitterDriver from './eventEmitterDriver';

function main(sources) {
  const buttonClick$ = sources.DOM.select('.my-button')
    .events('click')
    .mapTo({ type: 'button-clicked', payload: 'Button clicked!' });

  const eventEmitterSink$ = sources.EVENT.select('button-clicked')
    .events.map(payload => {
      return { type: 'log', payload };
    });

  const vdom$ = eventEmitterSink$.map(event => {
    return div('.container', [
      button('.my-button', 'Click me'),
      div('.log', event.payload),
    ]);
  });

  return {
    DOM: vdom$,
    EVENT: buttonClick$,
  };
}

const drivers = {
  DOM: makeDOMDriver('#app'),
  EVENT: eventEmitterDriver,
};

run(main, drivers);