RxJS和React的setState-延迟函数执行直到订阅

Question

RxJS有一个漂亮的函数，from mCallback，它接受一个函数，该函数的最后一个参数是回调，并返回一个可观察的。我想把它和React的setState函数结合起来，这样我就可以做一些类似的事情：

const setState = Rx.Observable.fromCallback(this.setState);
setState({ myState: 'Hi there!' }).concat(....)

因此，任何链接到setState的操作都保证在设置状态之后发生，最重要的是，只有在有活动订阅服务器时才会调用setState。

我注意到的是，即使没有订阅，setState也被正确地调用，因为它被定义并设置了我的组件的状态。所以如果我有：

networkSignal.flatMap((x) => {
    return setState({ myState: 'test' });
});

函数setState立即被调用，但是它产生的观察者在有订阅者之前不会发送下一个。我想要的是函数只在有订阅者时调用。

查看源代码，您可以看到RxJS返回一个函数，该函数在执行时创建一个可观察的但立即调用该函数——回调参数。

Answer 1

fromCallback返回一个函数，该函数在执行时返回一个可观察值。可观察到的是函数调用的异步结果将流动的地方。

要延迟函数的执行，可以使用。延迟。例如：

const setState = Rx.Observable.fromCallback(this.setState);
const deferred$ = Rx.Observable.defer(function (){return setState({ myState: 'Hi there!' }).concat(....)});
// Later on
deferred$.subscribe(...)

在这里和这里被问到的问题，其答案使用了相同的技巧