从setTimeout（Rxjs）返回可观察值

Question

如何从setTimeout返回可观察值？

send(action):Observable<any>{ 
    if(this.readyState === 0){ 
    setTimeout(() => this.send(action), this.timeout); 
    } 
    else{ 
    // observable is an Rxjs observable.... 
    return this.observable$.take(1); 
    } 
} 

---

复制和粘贴例如：

let observable$ = Rx.Observable.fromArray([1, 2, 3, 4, 5]); 
timeout = 40; 
// if you switch this to 1 it works.. 
readyState = 0; 
setTimeout(() => readyState = 1, 120); 

send().subscribe(c => console.log(c)); 

function send(action){ 
    if(readyState === 0){ 
    setTimeout(() => send(action), timeout); 
    } 
    else{ 
    return observable$.take(1); 
    } 
} 

Answer 1

像这样的东西（你不能返回从setTimeout()任何东西）：

send(action):Observable<any>{ 
    if(this.readyState === 0){ 
     return Observable.timer(this.timeout) 
     .mergeMap(() => this.send(action)) 
     .take(1); 
    } 
    else{ 
     // observable is an Rxjs observable.... 
     return this.observable$.take(1); 
    } 
}