Nikky
12/03/2020, 1:28 PM@OptIn(ExperimentalStdlibApi::class)
val wrappedEvents = buildList {
// collect all events in ingestChannel until empty
do {
val ingested = ingestChannel.poll()
if (ingested != null) {
add(ingested)
}
} while (ingested != null)
}
// processing events afterwards
Dominaezzz
12/03/2020, 3:32 PMNikky
12/03/2020, 3:33 PMDominaezzz
12/03/2020, 3:38 PM