Skip to main content

Crate selium_messaging

Crate selium_messaging 

Source
Expand description

In-memory asynchronous channel implementation with configurable backpressure.

Structs§

Channel
In-memory, asynchronous, many-to-many byte channel with explicit backpressure semantics.
ChannelDriver
Runtime driver for channel hostcalls
ChannelStrongIoDriver
Runtime driver for strong read/write hostcalls
ChannelWeakIoDriver
Runtime driver for weak read/write hostcalls
StrongReader
Reader that prevents overwriting unread bytes.
StrongWriter
Writer that maintains a persistent tail slot and participates in backpressure accounting.
WeakReader
Reader that sacrifices retention to avoid blocking writers.
WeakWriter
Writer that relinquishes its tail slot when idle.

Enums§

Backpressure
Backpressure policy for writers when the buffer is full.
ChannelError
Channel operation errors.
Reader
Convenience type for implementors to treat both reader types as one.
Writer
Writable handle into a Channel.