tap() isn’t triggered in RXJS Pipe

by

Imagine RxJS pipes like actual, physical pipes with a valve at the end. Each pipe will “modify” the liquid that is flowing through it, but as long as the valve at the end is closed, nothing will ever flow.

So, what you need, is to open the valve at the end. This is done by subscribing to the observable pipe. The easiest solution is:

this.actions$.pipe(
    ofType(LayoutActions.Types.CHANGE_THEME),
    takeUntil(this.destroyed$),
    tap(() => {
        console.log('test')
    }),
).subscribe(_ => console.log("water is flowing!"));

More Related Contents:

  1. FormControl.detectchanges – why use distinctUntilChanged?
  2. Angular/RxJS When should I unsubscribe from `Subscription`
  3. What is the correct way to share the result of an Angular Http network call in RxJs 5?
  4. Is it necessary to unsubscribe from observables created by Http methods?
  5. Angular HTTP GET with TypeScript error http.get(…).map is not a function in [null]
  6. Avoiding nesting subscriptions in Angular 2+?
  7. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  8. take(1) vs first()
  9. Subject vs BehaviorSubject vs ReplaySubject in Angular
  10. RxJS: takeUntil() Angular component’s ngOnDestroy()
  11. Angular Subscribe within Subscribe
  12. Passing Data with Subjects and Proxies
  13. How to cancel/unsubscribe all pending HTTP requests in Angular 4+
  14. How to make a sequence of http requests in Angular 6 using RxJS
  15. Angular subscribe elegant
  16. How to ‘wait’ for two observables in RxJS
  17. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  18. Behaviour subject initial value null?
  19. Observable.of is not a function
  20. fromPromise does not exist on type Observable
  21. Rxjs Retry with Delay function
  22. How to correctly import operators from the `rxjs` package
  23. Subscribing to a nested Observable
  24. What is pipe for in RxJS?
  25. How to throw error from RxJS map operator (angular)
  26. How to return observable from subscribe
  27. How to receive blob responses using Angular’s 2+ @angular/http module?
  28. Angular 5 to 6 Upgrade: Property ‘map’ does not exist on type Observable
  29. Angular2 watch for 302 redirect when fetching resource
  30. How to pass results between chained observables

Leave a Comment