Hi all! I'm new using channels and have a doubt about how to apply a kind of map in a `ConflatedBroa...

# coroutines

[bloder]

Hi all! I'm new using channels and have a doubt about how to apply a kind of map in a ConflatedBroadcastChannel, this is what I want:

val conflated = ConflatedBroadcastChannel<Int>()
val stringConflated: ConflatedBroadcastChannel<String>() = conflated.toStringConflated()

launch {
  stringConflated.consumeEach { println(it) }
}

launch {
  conflated.send(2) // will print "2" (as string)
}

I've tried some approachs to toStringConflated such as:

suspend fun ConflatedBroadcastChannel<Int>.toStringConflated(): ConflatedBroadcastChannel<String> =
    ConflatedBroadcastChannel<String>().apply {
        [e-mail] { // map value here }
    }

But when I apply a consumerEach to my ConflatedBroadcastChannel<Int> my ConflatedBroadcastChannel<String>() stops to consume values, is there a way to do what I'm trying?

[bloder]

found a solution:

suspend fun CoroutineScope.mappableConflated(conflated: ConflatedBroadcastChannel<Int>): ConflatedBroadcastChannel<String> =
    ConflatedBroadcastChannel<String>().apply {
        launch {
            conflated.consumeEach {
                [e-mail](it.toString())
            }
        }
    }

[bdawg.io]

Yeah, the issue is your consumeEach was causing your code to suspend before stringConflated was actually assigned