stream-consumer-task

在后台启动异步任务以消费流。

如果您的应用程序需要消费多个RabbitMQ队列或Kafka主题，这很有用。

入门

添加到您的Cargo.toml

[dependencies]
...
stream-consumer-task = "0"
...

您可以查看示例以了解如何使用该库。

架构

任务接受两个参数：一个流和一个项目处理器。

每次流中有新项目可用时，消费者都会为其启动一个新任务。

项目处理器接受两个参数：来自流的项和一个用于处理优雅关闭的Receiver<()>。

如果消费者停止，将向所有任务发送停止信号，并等待它们终止。

贡献

查看CONTRIBUTING.md。