for the position `#1` you could introduce a `scan`...

# rx

[kioba]

for the position #1 you could introduce a scan operator to store a map of messages. or even keep a view state