pull-stream for DOM events

index.js

// http://www.webpackbin.com/EJxIbvTSW
import pull from 'pull-stream'
import {click /*, mouseover, pullEvent*/ } from './pull-dom-events'
const {filter, map, take, through, drain} = pull

const throughs =
    pull(
        filter(event => event.target.matches('.only-me')),
        map(event => event.target.textContent),
        through(data => console.count(data)),
        take(10)
    )

pull(click(document), throughs, drain())

pull-dom-events.js

export const pullEvent = function pullEvent(type, elm, capture = false) {
    let callback
    const handler = function(evnt) {
        if (callback) {
            return callback(null, evnt)
        }
    }
    elm.addEventListener(type, handler, capture)
    return function read(end, next) {
        if (end) {
            elm.removeEventListener(type, handler, capture)
            return next(end)
        }
        callback = next
    }
}

export const click = (elem, capture) => pullEvent('click', elem, capture)
export const mouseover = (elem, capture) => pullEvent('mouseover', elem, capture)