Module core 

Async-first core: actor-style Request / Subscribe + their drivers.

Exposed as motorcortex_rust::core::*. The blocking façade under motorcortex_rust::blocking::* is a thin sync wrapper over these types.

See ARCHITECTURE.md for the design rationale.

Re-exports

pub use state::ConnectionState;

Modules

state

Connection state published by the driver to consumers via tokio::sync::watch. See ARCHITECTURE.md §“ConnectionState”.

Structs

Missed

Emitted by Subscription::stream when the consumer falls behind the bounded broadcast ring. The inner u64 is the number of samples the ring overwrote before the consumer got back to it — callers can use it to decide whether to reset derived state or just keep going.

Request

Async handle for request/reply RPCs.

Subscribe

Async handle for the pub/sub channel.

Subscription

Async-side subscription handle. Returned by crate::core::Subscribe::subscribe.

Type Aliases

StreamResult

Convenience alias for the Stream’s item type.