I can share ("fan-out") a Flow between multiple co...

# coroutines

[diesieben07]

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.

[Zach Klippenstein (he/him) [MOD]]

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

[louiscad]

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.

[diesieben07]

val shared = data.onCompletion<ByteBuffer?> { emit(null) }
                .shareIn(this, sharingStartedAfter(delegates.size))
                .takeWhile { it != null }
                .filterNotNull()

[diesieben07]

Thanks. I hate it. 😄

[diesieben07]

But it does work.