How to process spreads with reactive nodes

[schlonzo]

hi all,

I would like to filter a large spread in the background. What’s the best way to do this with reactive nodes? I understand the workflow for one observable, but how do I process whole speads?

I feed a "Spread<Float32>" into the "ToObservable(Sequence)" and it outputs "Observable<Float32>

How do I access the individual elements async?

[antokhio]

I don’t think that it works that way, basically you subscribed to spread changes like this.
I think you need a task region, and you should HoldLatest the task region output…

[tonfilm]

@schlonzo

How do I access the individual elements async?

It’s a common misconception that observables are async or in another thread. They can be, but it depends on how they are set up.

If you do it like in the patch, you get one event per slice, hence the type. And all events will be fired in the same frame right after each other.

Only if you use ToBackground, then the events will be put on background Tasks.

Maybe you wanted the normal ToObservable with ToBackground and then do normal spread ops in the regions?