0

根据操作员创建指南，我尝试将一些我曾经使用过的操作员链接到另一个操作员，但没有任何成功。

function mySimpleOperator(actionName, iterable$, functionThatReturnAnObservable) {
   return Observable.create(subscriber => {
     var source = this;
     var subscription = source
       .interval(500)
       .skipUntil(iterable$.filter(({ action }) => action.type === actionName))
       .take(1)
       .flatMap(functionThatReturnAnObservable)
       .subscribe(value => {
         try {
           subscriber.next(value);
         } catch(err) {
           subscriber.error(err);
         }
     }, 
     err => subscriber.error(err),
     () => subscriber.complete());

     return subscription;
   });
}

Observable.prototype.mySimpleOperator = mySimpleOperator;

这个函数只是开始一个间隔，并且会被跳过，直到 actionName 被发出。

但是当我尝试使用我的运营商时

Observable.mySimpleOperator('APP_READY', source$, () => Observable.of({ type: 'DONE' })

它抛出一个错误

Observable.mySimpleOperator is not a function

但是，如果我在我的新操作员之外进行间隔调用，它会起作用吗？！

Observable.interval(500).mySimpleOperatorWithoutIntervall('APP_READY', source$, () => Observable.of({ type: 'DONE' })

有什么解决办法吗？:)

4

1 回答 1

1

您尚未将运算符添加到您将其添加到对象的Observable.prototype对象中。这意味着它只会Observables以实例方法的形式出现。您需要将其添加到 Observable 作为Observable.mySimpleOperator.

在内部，您需要更改source.interval(500)为Observable.interval(500)静态方法。

于 2016-03-06T09:02:56.893 回答