docs.rs failed to build rxrs-0.1.0-alpha2
Please check the build logs for more information.
See Builds for ideas on how to fix a failed build, or Metadata for how to configure docs.rs builds.
If you believe this is docs.rs' fault, open an issue.
Please check the build logs for more information.
See Builds for ideas on how to fix a failed build, or Metadata for how to configure docs.rs builds.
If you believe this is docs.rs' fault, open an issue.
Visit the last successful build:
rxrs-0.2.0-beta3
🌱 This project is currently at its early stage... most of the features are experimental!
🦀 Contributions Are Welcome!
Example
Basics
Output:
)
)
)
)
)
Play with gtk-rs
//(lib for this demo is also a WIP)
let slider = new_with_range;
// create an `Observable` from the slider's `value_changed` event
event!
.start_with // events (signals) don't emit an initial value, so we give it one
.debounce // debounce with 250ms to limit input frequency
.observe_on // change to a worker thread
.map // do hard (or blocking) jobs on that thread
.observe_on // schedule results back to main thread ...
.subf;
File Structure
src
├── behaviour_subject.rs
├── connectable_observable.rs
├── fac
│  ├── create.rs
│  ├── mod.rs
│  └── timer.rs
├── lib.rs
├── observable.rs
├── op
│  ├── concat.rs
│  ├── debounce.rs
│  ├── filter.rs
│  ├── map.rs
│  ├── mod.rs
│  ├── multicast.rs
│  ├── observe_on.rs
│  ├── publish.rs
│  ├── skip.rs
│  ├── sub_on.rs
│  ├── take.rs
│  ├── take_until.rs
│  └── tap.rs
├── scheduler.rs
├── subject.rs
├── subscriber.rs
├── unsub_ref.rs
└── util
├── arc_cell.rs
├── atomic_option.rs
└── mod.rs
TODO
- basic operators,factories,
Scheduler
s - refactor towards zero-cost abstractions
- WIP: advanced operators,factories,
Scheduler
s - WIP: provide practical examples
- docs
- release a crate