RxRust:Rust 编程语言的React式扩展

这是响应式流的一个实现，在高层次上，它是从定义的接口和协议中分离出来的。 它还从 clojures Transducers 中汲取了很多灵感，因为它试图将执行工作的功能与其管道分离。 它通过策略来做到这一点。 这些影响发布者/处理器将如何使用和输出数据。 建立在接口（面向客户的部分）之上的高级 API 比基于 Java 的 Rx 库更多地从 Elm 中汲取灵感。 核心类型如下： Producer<Strategy> 生产者是大部分动作发生的地方。 它通过 Subscriber::on_next 方法生成数据并一次向其订阅者提供数据。 如果它有多个订阅者，它如何为每个订阅者提供数据取决于策略。 它还通过由订阅者（通过其订阅）提供请求数量来使用推回机制限制其输出。 希望生产者可以像 proc 一样简单，依靠策略和订阅对象来完成大部分繁重的工作，而 proc 只做数据转