According to this artcle, onComplete and onError function of the subscribe are mutually exclusive.    Meaning either onError or onComplete events will fire up in my subscribe. I have a logic block which needs to be executed whether I receive an error...

I ran into an interesting issue today. I'm working on an app where we have file uploads, and we want to implement a progress bar. The app is written using React/Redux/Redux-Observable. I want to dispatch actions for upload progress. Here's wh...

I have a code where for each of the ids I am making an ajax request and processing them as results come in. Here is a simple replica of my actual code and jsfiddle:  var ids = [1,2,3,4,5,6]; var ids$ = (id) => {     return Observable.of(id); }; va...

Experts, please tell me how to make sure that asynchronous initialization in the service constructor is complete when calling other functions in the class?    constructor() {     var sock = new SockJS(this._chatUrl);     this.stompClient = Stomp.over...

I'm trying to use an rxjs observable to delegate, but share, a piece of expensive work across the lifetime of an application.  Essentially, something like:  var work$ = Observable.create((o) => {   const expensive = doSomethingExpensive();   o...

I'm using websocket to receive data frame from hardware. The data frame is defined like this:  0xbb(head) ---data--- 0xee(tail)  the received data is store in Uint8Array, there maybe multiple frame:  var buffer = new Uint8Array([0xbb,0,0,0,0xee,0...

I believe the following code can be refactored using a flatMap but I cant seem to get it working as desired.   I understand flatMap essentially maps and then flattens, which is perfect for me as I'm using forkJoin so get an array of responses bac...

I am using RxJS 5 and have this method:  Queue.prototype.drain = function (obs, opts) {};   in the method, I would like to check if the user passed in an Observable for the first argument or if they omitted the Observable and just passed in an option...

I have been experimenting with RxJS for two weeks now, and although I love it in principle I just cannot seem to find and implement the correct pattern for managing state. All articles and questions appear to agree:   Subject should be avoided where...

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