Both operators are different. switchMap: Maps values to observable. Cancels the previous inner observable. Eg: fromEvent(document, ‘click’) .pipe( // restart counter on every click // First click: 0, 1, 2… // Second click: cancels the previous interval and starts new one. 0, 1, 2… switchMap(() => interval(1000)) ) .subscribe(console.log); map: Add projection with each value. … Read more
To debounce values you could use a Subject. A subject is both an observable and a observer. This means you can treat it as an observable and pass values to it as well. You could leverage this to pass the new values from the inner-component to it and debounce it this way. export class DebouncedComponent … Read more
Solution RxJS 5.4.2 should now work perfectly with TypeScript 2.4.1. Simply upgrade to 5.4.2+ if possible. npm install –save rxjs@^5.4.2 Then try restarting your editor and/or recompile if you don’t see an immediate change. If not, the below solution should work. Why it’s happening TypeScript 2.4 has a strictness change, and Subject<T> isn’t lifting to … Read more
From a quick look at your code I would say that your problem seems to be that you are not flattening the Observable that is returned from the refresh service. The catch operator expects that you will return an Observable that it will concatenate onto the end of the failed Observable so that the down … Read more
This is a simple solution, as you said in your question. I think there’s nothing simpler than what you already provided. <input type=”text” [ngModel]=”subject | async” (ngModelChange)=”subject.next($event)” />
Be careful that you are using RxJS v5 while your documentation link seem to be RxJS v4. I don’t remember specifics but I think that the share operator went through some changes, in particular when it comes to completion and resubscription, but don’t take my word for it. Back to your question, as you have … Read more
There is no requirement that you make a one-to-one in/out ratio. So you can emit multiple actions using mergeMap (aka flatMap) if you need to: const loaded = (results) => ({type: ‘RESULTS_LOADED’, results}); const otherAction = (results) => ({type: ‘MY_OTHER_ACTION’, results}); searchEpic = (action$) => action$ .ofType(‘SEARCH’) .mergeMap( Observable .fromPromise(searchPromise) // Flattens this into two … Read more
If you want to be sure it removes all Observers you can check it for yourself in https://github.com/ReactiveX/rxjs/blob/master/src/internal/Subject.ts#L91. It calls complete() on all Observers (Observers are typically just dumb objects implementing Observer interface) and then sets this.observers.length = 0;. So the answer is yes. Your approach is valid, it’s basically the same as Angular2 regularly … Read more
Since some people asked for the throttleTime directive, I’ll add it below. I chose to go this route because the debounceTime waits for the last click before firing the actual click event. throttleTime will not allow the clicker to click the button again until that time is reached and instead fires the click event immediately. … Read more