Angular Template: How to bind RXJS Observable and read its properties?
The async pipe does the subscription in view bindings <h3>{{(game | async)?.name}}</h3> The ? is only necessary when null values might be emitted.
rxjs
Rxjs toPromise() deprecated
Why is this happening? As mentioned here, these are the main reasons why toPromise is being deprecated: One goal was to remove it from the Observable prototype and turn it into a standalone util function. The naming of toPromise is not the best. Especially when used in combination with await it does not read very … Read more
combineLatest deprecated in favor of static combineLatest
In rxjs 6.5+ import { combineLatest } from ‘rxjs’; combineLatest([a$, b$, c$]); And for most applications it’s helpful to map the array of observables to a new value as well: combineLatest([a$, b$, c$]).pipe( map(([a$, b$, c$]) => ({ a: a$, b: b$, c: c$ })) ); Also see: https://www.learnrxjs.io/learn-rxjs/operators/combination/combinelatest
How to throw an observable error manually?
if (response.success == 0) { throw Observable.throw(response); } Edit for rxjs 6: if (response.success == 0) { throw throwError(response); }
Can I use RxJS vs Redux/context when trying to manage and access state in different components and handler methods [closed]
In short, they are very different libraries for very different purposes, but yes there are some vague similarities. Redux is a tool for managing state throughout the application. It is usually used as an architecture for UIs. Think of it as an alternative to (half of) Angular. RxJS is a reactive programming library. It is … Read more
What is the difference between BehaviorSubject and Observable?
BehaviorSubject is a variant of Subject, a type of Observable to which one can “subscribe” like any other Observable. Features of BehaviorSubject It needs an initial value as it must always return a value upon subscription, even if it has not received the method next() Upon subscription, it returns the last value of the Subject. … Read more
How to get last value from a Subject?
BehaviorSubject immediately emits the last value to new subscribers: @Injectable() export class SearchService { private searchResultSource = new BehaviorSubject<string>(”); setSearchResults(_searchResult: string): void { this.searchResultSource.next(_searchResult); } } ReplaySubject emits all previous events to new subscribers.
TypeScript – wait for an observable/promise to finish, and return observable
The problem is that we convert observable into different type… with .subscribe – while we should not (it does not return observable) public makeRequest = (): Observable<any> => { return this.myObservable().subscribe( … // this is wrong, we cannot return .subscribe // because it consumes observable and returns ISusbcriber ); } When we have an observable… … Read more
Angular filter Observable array
it should be: getProjectByName(name: String) { return this.projects .map(projects => projects.filter(proj => proj.name === name)); } you misunderstood about filter operator. The operator using to filter data return from stream. Your stream return array of object, so you need filter array to get you needed value. The solution above will return an array after filtered, … Read more
RxJS Observables nested subscriptions?
As mentioned in comments, you are looking for the flatMap operator. You can find more details in previous answers : How to do the chain sequence in rxjs Why do we need to use flatMap? Your example would read as : this.returnsObservable1(…) .flatMap(success => this.returnsObservable2(…)) .flatMap(success => this.returnsObservable3(…)) .subscribe(success => {(…)});