RxJS有一个漂亮的函数,fromCallback,它接受一个函数,其最后一个参数是回调,并返回一个Observable。我想把它与function的setState函数结合起来,这样我就可以做一些类似于:
const setState = Rx.Observable.fromCallback(this.setState);
setState({ myState: 'Hi there!' }).concat(....)因此,所有链接到setState的操作都保证在状态设置之后发生,最重要的是,在激活订阅服务器之前不会调用setState。
不过,我注意到,即使没有订阅,setState也是在定义并设置组件状态时被正确调用的。所以如果我有:
networkSignal.flatMap((x) => {
return setState({ myState: 'test' });
});函数setState立即被调用,但是它生成的观察者在有订阅者之前不会发送next。我想要的是函数只在有订阅者时调用。
查看源代码,您可以看到RxJS返回一个函数,该函数在执行时会创建一个可以观察到的函数,但会立即调用该函数--回调参数。
发布于 2016-01-19 07:41:50
fromCallback返回一个函数,该函数在执行时返回一个可观察的函数。这个可观察的函数调用的异步结果将在其中流动。
要延迟函数的执行,可以使用.defer。例如:
const setState = Rx.Observable.fromCallback(this.setState);
const deferred$ = Rx.Observable.defer(function (){return setState({ myState: 'Hi there!' }).concat(....)});
// Later on
deferred$.subscribe(...)https://stackoverflow.com/questions/34866762
复制相似问题