zanettin/incompose

/**
 * @author recompose (https://github.com/acdlite/recompose)
 */

import $$observable from 'symbol-observable';
import { createChangeEmitter } from 'change-emitter';
import { config as globalConfig } from './setObservableConfig';

export const createEventHandlerWithConfig = config => () => {
    const emitter = createChangeEmitter();
    const stream = config.fromESObservable({
        subscribe(observer) {
            const unsubscribe = emitter.listen(value => observer.next(value));
            return { unsubscribe };
        },
        [$$observable]() {
            return this;
        },
    });
    return {
        handler: emitter.emit,
        stream,
    };
};

const createEventHandler = createEventHandlerWithConfig(globalConfig);

export default createEventHandler;