RxJS 可观察对象属性

Question

我想用 RxJS 观察一个属性的变化。

interface Test {
  required: boolean;
  toObserve: boolean;
}

class TestClass {
  @Input() subject: Subject<Test>;

  registerHandlers() {
    this.subject.filter(element => element.required).subscribe(next =>
      // Observe a property of every element that was registered
      Observable.of(next.toObserve).subscribe(val => {
        if (val) {
          // DO SOMETHING
        } else {
          // DO SOMETHING ELSE
        }
      })
    );
  }
}

我得到了一个主题，新创建的对象被推入其中。有几个组件订阅了这些，并且应该对不同的属性变化做出反应。

在上面的示例中，如果设置了toObserve，我希望组件执行一些操作。这目前只工作一次 - 根据元素在subject.next(element) 注册时的值，执行正确的路径。

但是，一旦我更改了 element.toObserve 的值，什么都没有发生，订阅似乎也没有任何效果了。

Answer 1

不建议订阅订阅。我宁愿为您的主题创建一个运营商链并订阅它：

如果您想根据流中的特定属性在组件中执行一些副作用，可以使用 do 运算符：

interface Test {
  required: boolean;
  toObserve: boolean;
}

class TestClass implements OnInit {
  @Input() subject: Subject<Test>;

  ngOnInit() {
    this.registerHandlers().subscribe();
  }

  registerHandlers() {
    return this.subject
     .filter(element => element.required)
     .do(next => {
        if (next.toObserve) {
          // DO SOMETHING
        } else {
          // DO SOMETHING ELSE
        }
     });    
  }
}

Answer 2

抱歉，我认为您还没有完全了解如何正确完成订阅。

你有你的主题

@Input() subject: Subject<Test>;

并且您希望在主题更改时触发操作。然后将此订阅放入您的 ngOnInit() 方法中：

this.subject.subscribe(value => {
   // and here goes your evaluation
   if(value.toObserve) {
      // do something
   } else {
      // do something else
   }
});

你可以走得更远，做这样的事情

this.subject.subscribe(value => {
   // and here goes your evaluation
   if(value.toObserve) {
      // do something
   } else {
      // do something else
   }

   if(value.required) {
      // do something
   } else {
      // do something else
   }
});