文件名称:每晚rxrust-Reactive Extensions的Rust实现-Rust开发
文件大小:97KB
文件格式:ZIP
更新时间:2024-06-16 12:21:22
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)