我对TypeScript和RxJS还不是很熟悉,我想在另一个 Observable
完成后返回一个 Observable
:
我对TypeScript和RxJS还不是很熟悉,我想在另一个 Observable
完成后返回一个 Observable
:
public myObservable = () : Observable<boolean> => {
console.log('retrieving the token in DB');
return Observable.create(observer => {
setTimeout(() => {
observer.next(true);
observer.complete();
}, 5000);
});
}
public makeRequest = (): Observable<any> => {
return this.myObservable().subscribe(
function (x) {
console.log('I have the token, now I can make the HTTP call');
return this.http.get('http://jsonplaceholder.typicode.com/posts/1')
.map( (responseData) => {
return responseData.json();
})
.map((item:any) => {
return {
id: item.id,
userId: item.userId,
title: item.title,
body: item.body
};
});
},
function (err) {
console.error('Error: ' + err);
},
function () {
console.log('Completed');
});
}
我收到了这个错误:“返回的表达式类型 subscription 无法分配给类型 Observable<any>
”。
我完全理解这个错误 (一个 Observable 就像是一个流,而订阅是“观察”该流的事实),但我不知道如何“等待”一个 Observable
(或一个 promise) 完成后再返回一个新的 Observable
。我应该怎么做呢?