I can share ("fan-out") a Flow between multiple collectors while only collecting the original flow once using

shareIn

. However this does not support a finite flow, as

shareIn

makes the flow endless ("Shared flow never completes"). How can the collectors of the shared flow ever complete? Even if the original flow completes, they will continue to "hang", expecting more elements, because the shared flow never completes.

You could use a sentinel and takeWhile downstream of your sharing operator

Easiest if you have a non nullable type is to send null, and takeWhile not null, plus use

filterNotNull

to get back the non null type.