What is the difference between Observable and a Subject in rxjs?

by

In stream programming there are two main interfaces: Observable and Observer.

Observable is for the consumer, it can be transformed and subscribed:

observable.map(x => ...).filter(x => ...).subscribe(x => ...)

Observer is the interface which is used to feed an observable source:

observer.next(newItem)

We can create new Observable with an Observer:

var observable = Observable.create(observer => { 
    observer.next('first'); 
    observer.next('second'); 
    ... 
});
observable.map(x => ...).filter(x => ...).subscribe(x => ...)

Or, we can use a Subject which implements both the Observable and the Observer interfaces:

var source = new Subject();
source.map(x => ...).filter(x => ...).subscribe(x => ...)
source.next('first')
source.next('second')

More Related Contents:

  1. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  2. Subject vs BehaviorSubject vs ReplaySubject in Angular
  3. How to ‘wait’ for two observables in RxJS
  4. Angular 7 go offline?
  5. How to get current value of RxJS Subject or Observable?
  6. BehaviorSubject vs Observable?
  7. Angular 4 Interceptor retry requests after token refresh
  8. How can I close a dropdown on click outside?
  9. What is “callback hell” and how and why does RX solve it?
  10. Chaining Observables in RxJS
  11. How to do the chain sequence in rxjs
  12. Angular 2 – Chaining http requests
  13. Rxjs toPromise() deprecated
  14. How to achieve a debounce service on input keyup event in angular2 with rxjs
  15. How to cancel a subscription in Angular2
  16. What is the difference between BehaviorSubject and Observable?
  17. Upgrading to Angular 10 – Fix CommonJS or AMD dependencies can cause optimization bailouts
  18. Property ‘catch’ does not exist on type ‘Observable’
  19. How to implement a global loader in Angular
  20. Angular 2 Sibling Component Communication
  21. JS : Convert Array of Strings to Array of Objects
  22. How to force Angular2 to POST using x-www-form-urlencoded
  23. Angular ReactiveForms: Producing an array of checkbox values?
  24. Angular 4 pass data between 2 not related components
  25. Avoid Angular2 to systematically submit form on button click
  26. tap() isn’t triggered in RXJS Pipe
  27. Get Image or byte data with http
  28. TypeScript TS7015: Element implicitly has an ‘any’ type because index expression is not of type ‘number’
  29. binding data to angular checkbox
  30. iframe inside angular2 component, Property ‘contentWindow’ does not exist on type ‘HTMLElement’

Leave a Comment