Is it possible to transform a flow into a flow tha...

# coroutines

[julioromano]

Is it possible to transform a flow into a flow that emits a rolling window of N elements?

As if:

flowOf<Int>(0,1,2,3,4,5,6,7,8,9).magicOperator(2).collect { values: List<Int> ->
 print("${values}; ")
}

Would print:
0,1; 1,2; 2,3; 3,4; 4,5; 5,6; 6,7; 7,8; 8,9

[ephemient]

https://github.com/Kotlin/kotlinx.coroutines/issues/1290

[ephemient]

one possible implementation: https://kotlinlang.slack.com/archives/CRJCTR5PD/p1616471606038300?thread_ts=1616464660.037500&cid=CRJCTR5PD

[Joffrey]

I don't think chunked is relevant here, it's more about windowed or zipWithNext

[myanmarking]

you can try to hack a way with scan operator maybe ?

[julioromano]

The proposed implementation of zipWithNext did it great! Thanks!

[ephemient]

@Joffrey chunked isn't relevant but comments and PRs there include both chunked and windowed