distribute/actor

Values

start

pub fn start(
  initial_state: state,
  decoder: fn(BitArray) -> Result(msg, codec.DecodeError),
  handler: fn(msg, state) -> receiver.Next(state),
) -> Result(process.Subject(BitArray), actor.StartError)

Start an actor that receives and decodes typed messages.

This is a wrapper around receiver.start_typed_receiver. The returned Subject accepts BitArray messages.

start_global

</>

pub fn start_global(
  initial_state: state,
  decoder: fn(BitArray) -> Result(msg, codec.DecodeError),
  handler: fn(msg, state) -> receiver.Next(state),
) -> process.Subject(BitArray)

Start a global actor that can be registered with registry.register_typed.

This is a wrapper around receiver.start_global_receiver. The returned Subject has a Nil tag and accepts BitArray messages.