Jak zrobić sekwencję łańcucha w rxjs

Question

chciałbym aby coś takiego:

this._myService.doSomething().subscribe(result => { 
    doSomething() 
}); 
.then(() => dosthelse()) 
.then(() => dosanotherthing()) 

więc chciałbym aby łańcuch .then jak w obietnicy. Jak to zrobić w RxJ?

this._myService.getLoginScreen().subscribe(result => { 
     window.location.href = MyService.LOGIN_URL; 
     /// I would like to wait for the site to load and alert something from  the url, when I do it here it alerts the old one 
    }); 
    .then (alert(anotherService.partOfTheUrl()) 


getLoginScreen() { 
    return this.http.get(myService.LOGIN_URL) 
.flatMap(result => this.changeBrowserUrl()) 
.subscribe(result => //i want to do sth when the page is loaded//); 
} 

changeBrowserUrl(): Observable<any> { 
return Observable.create(observer => { 
window.location.href = myService.LOGIN_URL; 
observer.next(); 
}); 
} 

Answer 1

Możemy użyć metody toPromise który pozwala przekształcić obserwowalnych sekwencję do obietnicy.

Answer 2

Odpowiednikiem then dla obserwowalnych będzie flatMap. Można zobaczyć kilka przykładów stosowania tutaj:

• RxJS Promise Composition (passing data)
• Why we need to use flatMap?
• RxJS sequence equvalent to promise.then()?

Dla przykładu, można zrobić coś takiego:

this._myService.doSomething() 
    .flatMap(function(x){return functionReturningObservableOrPromise(x)}) 
    .flatMap(...ad infinitum) 
    .subscribe(...final processing) 

Przestrzegać rodzaje funkcji, które zwracają twoje funkcje, a także obserwowalne łańcuchy z flatMap będziesz musiał zwrócić obietnicę lub obserwowalne.

Answer 3

Jeśli wartością nieprzetworzoną jest lub dosanotherthing, operatorem jest map. Jeśli jest to obserwowalne, operatorem jest flatMap (lub odpowiednik).

Jeśli chcesz zrobić coś imperatywnie. Mam na myśli poza asynchronicznym łańcuchem przetwarzania, można użyć operatora do.

Zakładając, że dosthelse zwraca obserwowalne i dosanotherthing surowego obiektu, kod byłoby:

this._myService.doSomething() 
    .do(result => { 
    doSomething(); 
    }) 
    .flatMap(() => dosthelse()) 
    .map(() => dosanotherthing()); 

Zauważ, że jeśli wrócisz powrót metody subcribe będzie odpowiadać przedmiot subskrypcji i nie jest zauważalny. Obiekt subskrypcji służy głównie do anulowania obserwowalnego i nie może brać udziału w asynchronicznym łańcuchu przetwarzania.

W rzeczywistości przez większość czasu subskrybujesz na końcu łańcucha.

Więc chciałbym byłaby Twój kod w ten sposób:

this._myService.getLoginScreen().subscribe(result => { 
    window.location.href = MyService.LOGIN_URL; 
    /// I would like to wait for the site to load and alert something from  the url, when I do it here it alerts the old one 
    alert(anotherService.partOfTheUrl() 
}); 

getLoginScreen() { 
    return this.http.get(myService.LOGIN_URL) 
    .flatMap(result => this.changeBrowserUrl()) 
    .do(result => //i want to do sth when the page is loaded//); 
} 

changeBrowserUrl(): Observable<any> { 
    return Observable.create(observer => { 
    window.location.href = myService.LOGIN_URL; 
    observer.next(); 
    }); 
}