Name: Anonymous 2015-11-16 20:29
Why aren't you retards on this bandwagon yet?
All you need to do is write wrappers for everything!
All you need to do is write wrappers for everything!
Since this feels so familiar already, and I don't want you to get bored, let's do something new:
requestStream.subscribe(function(requestUrl) {
// execute the request
var responseStream = Rx.Observable.create(function (observer) {
jQuery.getJSON(requestUrl)
.done(function(response) { observer.onNext(response); })
.fail(function(jqXHR, status, error) { observer.onError(error); })
.always(function() { observer.onCompleted(); });
});
responseStream.subscribe(function(response) {
// do something with the response
});
}