rxjs - 对一次性事件使用 Observable

Question

我有 2 个函数(为简单起见，打开/关闭):

open(config){
    ...do something
    this.watchForClosing = Observable.create(..?..)
    return this.watchForClosing
}

close(closeArgs){
    this.watchForClosing.complete(closeArgs)
}

我想要实现的是一个像这样工作的调用方法:

myClass.open(myData)
.subscribe( closeArgs => console.log('closed'))

基本上，我希望调用函数调用open 函数并在调用close 函数时获得“回调”，并且正在努力寻找如何创建一个Observable 将执行此操作。感谢您的指导!

Answer 1

解决方案:我能够做类似的事情

class myClass {
    constructor(){
    this.observer = null
}
   open(componentConfig){
        return Observable.create(obs => {
            this.observer = obs
        })
    }

close(closeArgs){
        this.observer.next(closeArgs)
        this.observer.complete()
    }

}

抱歉，如果原来的问题太模糊了