Skip to main content

Crate async_flow

Crate async_flow 

Source
Expand description

This crate provides async primitives for flow-based programming (FBP).

Re-exports§

pub use crate::model::PortDirection;
pub use tokio::*;

Modules§

model
tokio

Structs§

RecvError
TryRecvError
TrySendError

Enums§

Error
PortEvent
A port’s state transition events (either connect, message, or disconnect).
PortState
A port’s possible states (either unconnected, connected, disconnected, or closed).
SendError

Traits§

Connection
InputPort
OutputPort
Port
The common interface for ports, whether for input or output.
Scheduler

Type Aliases§

Result