Plugin to allow use of RxJS in jQuery

jQueryRx.js

jQuery.fn.toObservable = jQuery.fn.toObservable || function (eventName, action) { 
    var dom = this;
    return Rx.Observable.create(function(observer) {
        var handler = function(ev) {
            if (action !== undefined) {
                action(ev);
            }
            else {
                if (ev && ev.preventDefault) {
                    ev.preventDefault();
                }
            }
            observer.onNext(ev);
        };
        dom.bind(eventName, handler);
        
        return function() {
            dom.unbind(eventName, handler);
        };
    });
}

// Example Usage:

test('listening to events', function() {
var received = '';
var subscription =
$(document)
.toObservable('foo')
.subscribe(function(e) { received += e.payload; });

$(document).trigger({ type: 'bar', payload : 'M'});
$(document).trigger({ type: 'foo', payload : 'A'});
$(document).trigger({ type: 'foo', payload : 'T'});
subscription.dispose();
$(document).trigger({ type: 'foo', payload : 'T'});

equals(received, 'AT');

});

// based on:
// https://github.com/mattpodwysocki/RxJSKoans/blob/master/koans/Answers/lesson4-Events.js