x.js

function socketIONoSuckstream(uri, event) {
    return from(function (push, end) {
        var socket = io.connect(uri)
        socket.on(event, push)
        // does socket.io even have a close / end??
    })
}