如何返回可观察到的。mongo光标查询中的fromEvent?

我发现使用以下代码更方便

export function findObs(collection: Collection<any>, queryConditions?: any) {
    const queryObj = queryConditions ? queryConditions : {};
    const queryCursor = collection.find(queryObj);
    return Observable.create((observer: Observer<Array<ObjectID>>): TeardownLogic => {
                            queryCursor.forEach(
                                doc => observer.next(doc),
                                () => observer.complete()
                            )
                        })
}

原因是 Observable.from 忽略 “完成” 事件,因此您永远不能输入 “未完成” 订阅者的功能。

另一方面,使用 Observable.create 允许控制光标的完成,从而触发 “未完成” 订阅者的功能。

这个 do 操作员接收可观察到的 next , error 和 complete 通知,但对可观察对象没有影响。即,从 做 操作员的 下一个 函数被忽略。因此,函数被传递给 subscribe 接收 Db .

而不是 做 ,您最可能要使用 switchMap ,将可观察到的事件平坦化为可观察到的流:

...
.switchMap(mongo_functions.query_tokens)
.subscribe(console.log);