fun listen(channelType: Type): Flow {
return channelFlow {
val shutdownable = listenCallback(channelType) {
tryEmit(it)
}
awaitClose {
shutdownable.close()
}
}
}