Top "Rxjs5" questions

The 5th version of the reactive extensions for javascript.

RxJS: Observable.create() vs. Observable.from()

What's the difference between these two? return Observable.create(function(observer) { if (array) observer.next([]); else observer.next(null); observer.…

javascript rxjs observable rxjs5
How to create Observable from function?

I want to call a function (synchronously) and then use its return value as an initial emission (subsequently chaining some …

javascript rx-java rxjs system.reactive rxjs5
Check if object is an Observable

I am using RxJS 5 and have this method: Queue.prototype.drain = function (obs, opts) {}; in the method, I would like …

javascript rxjs rxjs5
Rxjs, fromEvent to handle multiple events

What is the best way to handle multiple events on the same DOM node in rxjs 5.1? fromEvent($element, 'event_name') …

angular rxjs5 rxjs-dom
Hot and Cold observables: are there 'hot' and 'cold' operators?

I reviewed the following SO question: What are the Hot and Cold observables? To summarize: a cold observable emits its …

javascript angular rxjs reactive-programming rxjs5
Subscribe to multiple Observables (like chaining then() in Promises)

My Angular 2 application has 2 methods (GetCategories() and GetCartItems()) in a service , and both of these methods return Observables. In order …

angular rxjs rxjs5
How to convert an Observable to a ReplaySubject?

Here is what I'm doing now to convert an Observable to a ReplaySubject: const subject = new Rx.ReplaySubject(1); observable.subscribe(…

rxjs rxjs5
Can't find `combineLatest` in RxJS 5.0

The following code it's causing me a Observable.combineLatest is not a function using RxJS 5.0: let Observable = require('rxjs/Observable.…

rxjs rxjs5
Using RxJs and Angular 2 in order to deal with server-sent events

I am trying to display server-sent events emitted values in an angular 2 /RxJs app. The backend regularly sends individual strings …

angular server-sent-events rxjs5
Observable forkJoin not firing

I'm trying to use forkJoin on two Observables. One of them starts as a stream... If I subscribe to them …

angular typescript rxjs rxjs5