1

是否有可能？

更详细的问题

我有这样的事情：

const source = Rx.Observable.interval(500);
const transformed = source.mergeMap(() => Rx.Observable.timer(100));

transformedobservable 是新的observable 并且它没有连接到初始 observable source（我无法通过 访问它transformed，我认为）。是否有可能在使用运算符转换后以某种方式获得初始（在运算符应用之前）可观察？

我的情况

代码：

@AppendLoader()
@Effect()
getFriends$: Observable<Action> = this.actions$
  .ofType(friendsActions.GET_FRIENDS)
  .switchMap(() => {
    return this.friendsService.getFriends()
      .map((data: any) => new friendsActions.GetFriendsSuccessAction(data))
      .catch(() => of(new friendsActions.GetFriendsFailureAction()));
  });

和 AppendLoader：

function AppendLoader() {
  return function (target: any, propertyKey: string) {
    let observable: any = null;
    Object.defineProperty(target, propertyKey, {
      configurable: true,
      enumerable: true,
      get: () => {
        console.log('get');
        return observable;
      },
      set: (newObservable) => {
        console.log('set', newObservable);
        observable = newObservable;
        observable
          .subscribe((action: any) => {
            console.log(action);
          });
      }
    });
  };
}

我在那里有三个可观察的：

  • this.actions$（所有动作）
  • 从 this.action$ this.action$.ofType(friendsActions.GET_FRIENDS)（friendsActions.GET_FRIENDS类型的可观察对象）创建
  • 第三个可观察对象（第二个并switchMap应用于它）（GetFriendsSuccessAction/的可观察对象GetFriendsFailureAction）

我只能访问装饰器中的第三个 observable，因为这个 observable 在getFriends$属性中。

我想在 AppendLoader 装饰器中做一些动作。我想订阅列表中的第二个 observable，当发出值时，我想显示负载微调器（showLoader()例如）。我想订阅第三个 observable，当成功/失败值发出时，我想隐藏加载微调器。

4

1 回答 1

1

我简要检查了 RxJs5 源代码似乎是不可能的。但对于您的情况，您可以执行以下操作：

  1. 创建新的 observable 'forDecorator$'：

    second$ = this.actions$.ofType(friendsActions.GET_FRIENDS)
getFriends$ = second$.switchMap(() => {...});

forDecoratror$ = Observable.Merge(second$.mapTo("2nd"), getFriends$)

  2. 在“2nd”到来时在装饰器中调用 showloader()

请记住，一切都是流:-)

于 2017-08-02T11:30:15.990 回答