``` E/File$object: kotlinx.coroutines.channels.Clo...

# coroutines

[rook]

E/File$object: kotlinx.coroutines.channels.ClosedSendChannelException: Channel was closed
        at kotlinx.coroutines.channels.Closed.getSendException(AbstractChannel.kt:1048)
        at kotlinx.coroutines.channels.AbstractSendChannel.offer(AbstractChannel.kt:166)
        at kotlinx.coroutines.channels.ChannelCoroutine.offer(ChannelCoroutine.kt)

Untitled.kt

[rook]

I’m not quite sure what I’m doing wrong here. I get the Channel was closed error when I try to offer.

[Dominaezzz]

channelFlow<List<Foo>> {
    updateStream().subscribe({ offer(it) }, {})
    awaitClose {
        // unsubscribe
    }
}

[rook]

Ugh, such a RTFM moment. Thank you! @Dominaezzz