Racing and Interrupting Effects Over Time from a Stream

Hello, how can I race effects over time? I know I can use E.raceAll if I have the list of effects upfront, but in my use case I create effects over time (from a stream) and I want to interrupt all the other ones once I have a result. But then I still want to race again for new emitted effects

For example it might look something like this:
start effect 1
start effect 2
start effect 3
effect 2 succeeds so get its result and interrupt effects 1 and 3
start effect 4
start effect 5
effect 4 succeeds so get its result interrupt effect 5
etc...
Was this page helpful?