Firing a custom event in Rx JS

Question

I am trying to understand Reactive JS . In jQuery, I can fire custom events like

$(document).bind('eventbus', function(e, d) { console.log(d);});
$(document).trigger('eventbus', 'test');

and transmit data (ie, “test”). It is not clear how to do this in RxJS. I could try to convert jquery events as

var observable = $(document).ToObservable('eventbus');

but observable returns an event object, but not my data object. How to trigger custom events with data using RxJS? Do I always need to combine any other type of event? My goal is to create a simple eventbus using RxJS.

Answer 1

Even if your question is a little old and already answered, I would like to share my opinion with you.

, , Observables. jQuery , , , - , . . , Observable, RxJS , :

function Component(){
    var self = {};
    var subject = new Rx.Subject();

    //raise notifications this way
    //subject.OnNext("myData"); //could be anything, a string, an object, whatever

    self.getObservableSomething = function(){
        return subject.AsObservable();
    }
    return self;
}

Rx, , . , F #, , IEvent IObservable.

, jQuery.

Answer 2

Rx.Observable.FromJQueryEvent, jQuery, .ToObservable.

: jQuery + RxJS