kotlin - 如何将制作人与 Actor 联系起来？

Question

如何连接使用 produce 创建的生产者协程生成器，对于 Actor ，使用 actor 创建协程构建器？

基本上，我希望生产者的发送 channel 成为actor的接收 channel 。有没有简单的方法可以做到这一点？

我在文档中找不到任何允许我明确指定制作人或 Actor 使用的 channel 的内容。

Answer 1

假设以下定义:

val producer = produce<T> { ... }
val actor = actor<T> { ... }

您可以编写以下代码来启动辅助协程，将所有生成的消息发送给您的参与者:

launch { producer.toChannel(actor) }

如果您想等到复制作业完成，您只需在协程中使用 Producer.toChannel(actor) 即可。 toChannel 是一个终端操作，等待处理完成。