So the distinction seems to be: defer is good when you have something that creates/returns an observable already, but you don’t want that process to happen until subscription. create is good when you need to manually wrap an async process and create an observable. That creation is also deferred until subscription. To put it another … Read more
I’m going to describe the difference between them in terms of their Time versions as that’s how I understand them best. Both auditTime and debounceTime will initially start a timer when an event comes in. Both will wait the given amount of time before they emit an event. The difference is that debounceTime resets the … Read more
The main difference between PublishSubject and BehaviorSubject is that the latter one remembers the last emitted item. Because of that BehaviorSubject is really useful when you want to emit states. Why they make project field a BehaviorSubject and not PublishSubject ? Probably because they want to be able to retrieve the last emitted project with … Read more
Before RxJs 6: Observable.timer(0, 1000) will start immediately. RxJs 6+ import {timer} from ‘rxjs/observable/timer’; timer(0, 1000).subscribe(() => { … });
I would suggest that you use flatMap (now mergeMap in rxjs version 5) instead, which will let you collapse errors if you don’t care about them. Effectively, you will create an inner Observable that can be swallowed if an error occurs. The advantage of this approach is that you can chain together operators and if … Read more
Ok, If we ignore my dogmatic ways and ignore “subjects are good/bad” all together. Let us look at the problem space. I bet you either have 1 of 2 styles of system you need to ingrate to. The system raises an event or a call back when a message arrives You need to poll the … Read more