これはキャンセル可能なObservableの妥当な実装ですか？

Question

私はコールバックを取る関数と2つの約束を返す関数という多段階のプロセスを持っていますが、取り消しをサポートするObservableを構築したいと思います。私が持っているものは：

let observableFromEvent = evt => Observable.create(({ next, error, complete }) => { 
    let canceled 
    Promisify(callbackFn)(evt) 
     .then(r => !canceled && promiseF1(r)) 
     .then(r => !canceled && promiseF2(r)) 
     .then(next) 
     .then(complete, error) 
    return() => { 
     canceled = true 
    } 
}) 

私は何かを残しているか誰に教えてもらえますか？またはあまりにも多くを残した？ 私の意図した使用方法は次のとおりです。

event$.switchMap(observableFromEvent) 

それらが生み出されたときに、以前のキャンセル観測のシリーズを作成します。

あなたは、次のような単純なように、組み込みの演算子でそれを行うことができます

Answer 1

：

observableFromEvent = evt => Observable 
    .bindCallback(callbackFn)(evt) 
    .flatMap(promiseF1) 
    .flatMap(promiseF2)