Sha256: 1973a8da6dd5fc8ce66f13541d9d42b03873bc11e25c5c23759bc2ff7535c4e2
Contents?: true
Size: 737 Bytes
Versions: 14
Compression:
Stored size: 737 Bytes
Contents
var AnonymousSubject = Rx.AnonymousSubject = (function (__super__) {
inherits(AnonymousSubject, __super__);
function subscribe(observer) {
return this.observable.subscribe(observer);
}
function AnonymousSubject(observer, observable) {
this.observer = observer;
this.observable = observable;
__super__.call(this, subscribe);
}
addProperties(AnonymousSubject.prototype, Observer.prototype, {
onCompleted: function () {
this.observer.onCompleted();
},
onError: function (error) {
this.observer.onError(error);
},
onNext: function (value) {
this.observer.onNext(value);
}
});
return AnonymousSubject;
}(Observable));
Version data entries
14 entries across 7 versions & 1 rubygems