I don't fully understand your usecase but like thi...

# rx

[Paul Woitaschek]

I don't fully understand your usecase but like this you create a stream that mutates the state based on the previous emission