Crate reflux

source

Macros§

  • add_routine
    A simple macro to create a function that returns a coroutine.

Structs§

  • Broadcast
    An object that received data from a provided Receiver, and broadcasts the data to all subscribers.
  • Filter
    An object that uses a predicate function to determine whether some data can be passed through a network node
  • Funnel
    An object that receives data from multiple subscriber and channels the data to a single output.
  • Inlet
    Receives data from an external source and sends the data through a channel.
  • Outlet
    An object that receives data from a Reflux network and sends the data to some external sink.
  • Router
    An object that received data from a provided Receiver, and broadcasts the data to subscribers using a Round Robin algorithm.
  • Transformer
    An object that enables data mutation. After processing data a Transformer can yield three variants:
  • TransformerContext

Enums§