e.g. i have sequence of 4 flow<T> of undecoded byt...

# coroutines

[jimn]

e.g. i have sequence of 4 flowT of undecoded bytebuffers i want to index into 3 Flow<FlowT> as aggregate [0, 1, 2, 1] because i know the keys ahead of time. decoding can happen later in parrallel contexts.