【文件属性】：
文件名称：每晚rxrust-Reactive Extensions的Rust实现-Rust开发
文件大小：97KB
文件格式：ZIP
更新时间：2021-05-27 18:34:42
Rust Asynchronous
rxRust：Reactive扩展用法的零成本Rust实现将其添加到您的Cargo.toml：[依赖关系] rxrust =“ 0.8.3”示例使用rxrust :: rxRust：Reactive扩展用法的零成本Rust实现，将其添加到您的货运.toml：[依赖关系] rxrust =“ 0.8.3”示例使用rxrust :: prelude :: *;
让mut number = observable :: from_iter（0..10）;
//通过过滤器创建一个偶数流let even = numbers.clone（）。filter（| v | v％2 == 0）;
//通过过滤器创建一个奇数流，让odd =数字.clone（）。filter（| v | v％2！= 0）;
//再次合并偶数和偶数流even.merge（odd）.subscribe（| v | print！（“ {}”，v，））;
//“ 0 1 2 3 4 5 6 7
【文件预览】：
rxRust-master
----rustfmt.toml(146B)
----Cargo.toml(868B)
----.mergify.yml(1KB)
----.github()
--------workflows()
----missing_features.md(10KB)
----configs()
--------grcov.config.yml(293B)
----src()
--------subscriber.rs(3KB)
--------ops()
--------subscription.rs(7KB)
--------subject()
--------observer.rs(3KB)
--------subject.rs(7KB)
--------test_scheduler.rs(8KB)
--------scheduler.rs(7KB)
--------ops.rs(12KB)
--------lib.rs(957B)
--------type_hint.rs(412B)
--------observable.rs(35KB)
--------observable()
--------shared.rs(1KB)
----.vscode()
--------launch.json(855B)
--------settings.json(70B)
----CONTRIBUTING.md(3KB)
----LICENSE(1KB)
----guide()
--------developing.md(1KB)
----README.md(3KB)
----.gitignore(52B)
----CHANGELOG.md(13KB)