I am trying to replace all the promises that my functions return with Observables. From this post, I learned that I should no longer use "new Observable" Observable.forkJoin and array argument
What is the RxJS v5 syntax to achieve this as such to achieve asynchronous waiting?
thirdFunction() {
let _self = this;
return new Observable(function(observer) {
...
observer.next( responseargs );
observer.complete();
});
}
Thank you greatly for help you can offer.
Creating Observableslink The following example creates an Observable to emit the string 'hi' every second to a subscriber. import { Observable } from 'rxjs'; const observable = new Observable(function subscribe(subscriber) { const id = setInterval(() => { subscriber.next('hi'); }, 1000); });
You can't return an observable from subscribe but if you use map instead of subscribe then an Observable is returned.
This is a JavaScript object that defines the handlers for the notifications you receive. The subscribe() call returns a Subscription object that has an unsubscribe() method, which you call to stop receiving notifications.
An Observable is basically a function that can return a stream of values to an observer over time, this can either be synchronously or asynchronously. The data values returned can go from zero to an infinite range of values.
There are a set of methods to create observables for different use cases:
This link provides a list of them by category:
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With