Difference between .unsubscribe to .take(1)

by

Each serves a different purpose so it’s hard to compare them.

In general if you take this source:

const source = range(1,3);

… and consume it with subscribe() followed immediately by unsubscribe():

source.subscribe(
  console.log,
  undefined, 
  () => console.log('complete')
).unsubscribe();

… then all values from source are going to be emitted even though we called unsubscribe() right after subscribing. This is because the code is still strictly sequential (synchronous) and the source is a cold Observable.

1
2
3
complete

Btw, try adding delay(0) operator to make source.pipe(delay(0)).subscribe(...).unsubscribe(). This makes emitting values asynchronous using an actual setTimeout() call and for this reason unsubscribe() is called before any next handlers and is discarded immediately.

In other words unsubscribe() let’s you stop receiving values anytime. Even when the source hasn’t emitted any value (we never receive any complete notification).

Using take() operator limits the chain to only emit a specific number of values.

source.pipe(
  take(1),
)
.subscribe(
  console.log,
  undefined,
  () => console.log('complete')
);

This just emits a single value and completes:

1
complete

Even if you add .unsubscribe() the result would be the same.

See live demo: https://stackblitz.com/edit/rxjs-tbu5kb

So take() is an operator while unsubscribe() is a method on a Subscription object. These two things are often interchangeable but they never fully substitute each other.

Jan 2019: Updated for RxJS 6

More Related Contents:

  1. When to use asObservable() in rxjs?
  2. How to force observables to execute in sequence?
  3. RxJS Observables nested subscriptions?
  4. Rxjs: Observable.combineLatest vs Observable.forkJoin
  5. How to get an observable to return data immediately and every 5 seconds thereafter
  6. Merge subarrays using Observables
  7. Angular/RxJS When should I unsubscribe from `Subscription`
  8. What is the correct way to share the result of an Angular Http network call in RxJs 5?
  9. Observable type error: cannot read property of undefined
  10. Angular 2 – Return data directly from an Observable
  11. How to return value from function which has Observable subscription inside?
  12. Chaining RxJS Observables from http data in Angular2 with TypeScript
  13. What are the semantics of different RxJS subjects?
  14. Chaining Observables in RxJS
  15. RxJS: takeUntil() Angular component’s ngOnDestroy()
  16. Promise.all behavior with RxJS Observables?
  17. How to create an RXjs RetryWhen with delay and limit on tries
  18. ‘of’ vs ‘from’ operator
  19. Rxjs One Observable Feeding into Another
  20. How to make one Observable sequence wait for another to complete before emitting?
  21. How to achieve a debounce service on input keyup event in angular2 with rxjs
  22. Is it good to call subscribe inside subscribe?
  23. Return an empty Observable
  24. TypeError: You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable
  25. fromPromise does not exist on type Observable
  26. RxJs get value from observable
  27. ngrx effects error handling
  28. How to return observable from subscribe
  29. How to return value inside subscribe Angular 4
  30. Observable Finally on Subscribe

Leave a Comment