-
rxrust
Reactive Extensions
-
futures-rx
Rx implementations for the futures crate
-
thubo
high-performance TX/RX network pipeline featuring strict priority scheduling, automatic batching, and message fragmentation
-
pro-cli
Pro: A fast Python package manager written in Rust
-
rx_bevy
Reactive Extensions for the Bevy game engine
-
rx_core_macro_common
Macro helper functions used in rx_core and its crates
-
pro-core
Core library for Pro Python package manager
-
another-rxrust
A different implementation than
rxRustfor easier use ofReactiveXinRust -
fp_rust
Implement fp features for Rust
-
embassy-net-driver
Driver trait for the
embassy-netasync TCP/IP network stack -
rx_core_subject_publish
publish subject for rx_core
-
rx_core_operator_composite
composite operator for rx_core
-
rx_event_bus
agnostic reactive extensions event bus utilising rxRust under the hood
-
rx_core_operator_throttle_time
throttle_time operator for rx_core
-
rx_core_testing
tools for testing rx_core
-
rx_core_operator_map
map operator for rx_core
-
rx_core_observable_connectable
connectable observable for rx_core
-
rx_core_scheduler_ticking
rx_core mock scheduler for tests and examples
-
roam-schema
Rust-level schema structs per docs/content/rust-spec
-
esp-wifi-hal
An experimental driver for the Wi-Fi peripheral on ESP32-series chips
-
roam-session
Session/state machine (handshake, request_id/channel_id routing, flow control)
-
rx_core_operator_catch
catch operator for rx_core
-
rx_core_subscriber_higher_order
higher_order subscriber provider for rx_core
-
rx_core_notification_store
Stateful notification stores for rx_core
-
easerx
A reactive MVI (Model-View-Intent) framework for Rust
-
pro-plugin
Plugin SDK for Pro Python package manager
-
rx_core_subject_behavior
behavior_subject for rx_core
-
rx_core_subscriber_higher_order_concurrent
concurrent subscriber for rx_core
-
rx_core_notification_variadics
Types to deal with variadics for rx_core
-
rx_core_subscriber_higher_order_map
higher_order_map subscriber for rx_core
-
roam-tracing
Cross-cell tracing for roam RPC framework
-
rx_core_subscriber_higher_order_all
higher_order_all subscriber for rx_core
-
rx_core_subscription_inert
rx_core inert subscription; always closed
-
roam-http-bridge
HTTP/JSON bridge for roam RPC services
-
rx_core_operator_exhaust_map
exhaust_map operator for rx_core
-
rx_core_common
rx_core's core traits and implementations
-
rx_core_operator_materialize
materialize operator for rx_core
-
rx_core_operator_adsr
adsr operator for rx_core
-
rx-plugin
Plugin SDK for T-Rex Python package manager
-
can-isotp-queue
Queue/actor adapter for split ISO-TP TX/RX endpoints across async runtimes
-
rx_core_operator_find
find operator for rx_core
-
rx_bevy_common
rx_bevy allocation context
-
rx_bevy_observable_proxy
rx_bevy proxy observable, relays events from another observable
-
rx_core_operator_scan
scan operator for rx_core
-
rx_core_operator_merge_map
merge_map operator for rx_core
-
rx_core_operator_concat_map
concat_map operator for rx_core
-
rx_core_operator_tap
tap next operator for rx_core, for the simple use cases where you don't want to define an entire observable to peek into one
-
rx_core_observable_combine_changes
combine_changes observable for rx_core
-
rx_core_operator_switch_map
switch_map operator for rx_core
-
rx_core_operator_delay
delay operator for rx_core
-
rx_core_observable_combine_latest
combine_latest observable for rx_core
-
rx_core_operator_error_boundary
error boundary operator for rx_core. ensures at the type level that no errors are coming from upstream.
-
rx_bevy_observable_event
rx_bevy event observable, a glue between regular bevy events and observables
-
rx_core_operator_subscribe_on
subscribe_on operator for rx_core
-
rx_core_operator_map_never
map_never operator for rx_core
-
rx_core_operator_observe_on
observe_on operator for rx_core
-
rx_core_operator_share
share operator for rx_core
-
rx_core_subject_async
async_subject for rx_core
-
rx_core_operator_on_next
on_next operator for rx_core
-
rx_core_operator_map_error
map_error operator for rx_core
-
rx_core_operator_map_into
map_into operator for rx_core
-
rx_bevy_observable_keyboard
rx_bevy keyboard observable
-
rx_core_observable_join
join observable for rx_core
-
rx_core_operator_enumerate
enumerate operator for rx_core
-
rx_core_operator_debounce_time
debounce_time operator for rx_core
-
rx_core_operator_fallback_when_silent
fallback_when_silent operator for rx_core
-
rx_core_operator_dematerialize
dematerialize operator for rx_core
-
rx_bevy_observable_resource
rx_bevy resource observable
-
rx_core_operator_pairwise
pairwise operator for rx_core
-
rx_core_operator_lift_option
lift_option operator for rx_core
-
rx_core_operator_filter
filter operator for rx_core
-
rx_core_operator_element_at
element_at operator for rx_core; Emit the value at the given index then complete
-
rx_core_operator_tap_next
tap next operator for rx_core, for the simple use cases where you don't want to define an entire observable to peek into one
-
rx_core_operator_into_result
Error handling operator. Captures upstream values and errors into a
Result. -
rx_core_operator_lift_result
lift_result operator for rx_core
-
rx_core_operator_retry
retry operator for rx_core
-
rx_core_observable_zip
zip observable for rx_core
-
rx_core_operator_on_subscribe
on_subscribe operator for rx_core
-
rx_core_operator_find_index
find_index operator for rx_core
-
rx_core_subject_provenance
provenance_subject for rx_core
-
rx_core_operator_first
first operator for rx_core
-
rx_core_observable_iterator_on_tick
iterator observable for rx_core, emitting on discrete ticks instead of immediately
-
rx_core_operator_skip
skip operator for rx_core
-
rx_core_observable_interval
interval observable for rx_core
-
rx_core_operator_filter_map
filter_map operator for rx_core
-
rx_core_operator_count
count operator for rx_core
-
rx_core_operator_take
take operator for rx_core
-
rx_core_operator_concat_all
concat_all operator for rx_core
-
rx_core_operator_is_empty
is_empty operator for rx_core
-
rx_core_operator_merge_all
merge_all operator for rx_core
-
rx_core_observable_throw
throw observable for rx_core
-
rx_core_observer_print
print observer for rx_core, it prints out received values
-
rx_core_observable_create
create observable for rx_core
-
rx_core_observable_timer
timer observable for rx_core
-
rx_core_observer_fn
fn observer for rx_core, it calls a closure
-
rx_core_subject_replay
replat_subject for rx_core
-
rx_core_operator_identity
identity operator for rx_core; a no-op operator mainly used to define input types for composite operators
-
rx_core_observable_iterator
iterator observable for rx_core
-
rx_core_operator_end_with
end_with operator for rx_core
-
rx_core_operator_with_latest_from
with_latest_from operator for rx_core
-
rx_core_operator_buffer_count
buffer_count operator for rx_core
-
rx_core_observable_never
never observable for rx_core
-
rx_core_operator_reduce
reduce operator for rx_core
-
rx_core_observable_deferred
deferred observable for rx_core
-
rx_core_observable_just
just observable for rx_core; emits a single value
-
rx_core_observable_closed
closed observable for rx_core; immediately unsubscribes
-
rx_core_observable_empty
empty observable for rx_core
-
rx_bevy_observable_message
rx_bevy message observable
-
rx_core_operator_finalize
finalize operator for rx_core
-
i2c-pio
I2C driver implementation using the RP2040's PIO peripheral
-
rx_core_observable_concat
concat observable for rx_core
-
rx_core_observable_merge
merge observable for rx_core
-
rx_core_operator_start_with
start_with operator for rx_core
-
rx_core_subscriber_higher_order_switch
switch subscriber for rx_core. Upon receiving an observable, subscribes to it immediately, unsubscribing the previous one.
-
rx_core_subscriber_higher_order_exhaust
exhaust subscriber for rx_core
-
rx_core_operator_switch_all
switch_all operator for rx_core
-
swap-queue
A lock-free thread-owned queue whereby tasks are taken by stealers in entirety via buffer swapping
-
rx_core_operator_exhaust_all
exhaust_all operator for rx_core
-
rx_core_observer_noop
noop observer for rx_core, it doesn't do anything
-
ifstat-rs
report network interface statistics
-
wasmrs-rx
Base host and client implementations of the wasmRS RSocket protocol
-
rx_rust_mp
A protoype implementation of the ReactiveX API in Rust using a message passing approach
-
emcyphal-driver
Driver interface for Emcyphal network stack
-
rx-editor
a modern, extensible pixel editor
-
cc1101-rust
Rust interface to the CC1101 Linux driver
-
epoxy_frp
The Reactive Glue for Frontend Applications
-
tokio-stream-ext
Stream extension with new operators, this will grow over the time
-
radio-at86rf23x
Driver for the Microchip at86rf23x series of 2.4GHz RF ICs
-
vnstat_parse
Parse output from
vnstat --onelinecommand -
rx_core_macro_subject_derive
rx_core subject derive, implements associated type only traits
-
rx_core_macro_subscription_derive
rx_core subscription derive, implements associated type only traits
-
rx_core_macro_observer_derive
rx_core observer derive, implements associated type only traits
-
smoltcp_null_modem
smoltcp null modem drivers
-
rx_core_macro_subscriber_derive
rx_core subscriber derive, implements associated type only traits
-
niu2x-rx
minimal helper library
-
rx_core_macro_operator_derive
rx_core operator derive, implements associated type only traits
-
rx_core_macro_observable_derive
rx_core observable derive, implements associated type only traits
-
rx_core_macro_executor_derive
rx_core executor derive, implements associated type only traits
-
rx_core_macro_scheduler_derive
rx_core scheduler derive, implements associated type only traits
-
rx_core_macro_work_derive
rx_core work derive, implements associated type only traits
-
tcp-clone
TCP proxy server with ability to send client up- and/or downstream to observer(s)
-
ebpf
Linux extended BPF access
-
rx_gtk
rx utils for gtk-rs
-
crate_IA7_GPS
Get data from GPS with UART
-
JL_IA7
Getting datas from GPS
Try searching with DuckDuckGo.