Is there a `collect` variant for `Flow` that allow...

# coroutines

[louiscad]

Is there a collect variant for Flow that allows to access the previous value, or null for initial value?

[gildor]

you need something like windowed that will emit Pair(null, first) element

[elizarov]

Not yet. Create an issue with your use-case please.

[gildor]

not sure that such operator exists

[pakoito]

you need to combine with itself but skipping one value, it's a classic zipping structure

[pakoito]

mergeAsTuple(flow, flow.skip(1)).map { (previous, current) -> ... }

[pakoito]

dunno what are the API equivalents

[pakoito]

@elizarov use case is any state machine that keeps track of transitions

[jw]

that should really be something like .publish { zip(flow, flow.skip(1), ::Pair) } to avoid subscribing upstream twice

[pakoito]

it'd work if flow there was shared() first too, right?

[jw]

only if it's async so that's unsafe. if it's synchronous the entire stream will be consumed in the first subscription before flow.skip(1) is subscribed to yielding either two upstream subscriptions or no output

[pakoito]

are we talking Rx or Kx?

[pakoito]

...wait I may be thinking cached() for Rx

[pakoito]

it's been a while

[pakoito]

¯\_(ツ)_/¯

[jw]

i'm sorta talking about both since they're really the same thing