distribute - v3.1.0

distribute/actor

Values

child_spec

</> 
pub fn child_spec(
  typed_name: registry.TypedName(msg),
  initial_state: state,
  handler: fn(msg, state) -> receiver.Next(state),
) -> supervision.ChildSpecification(global.GlobalSubject(msg))

OTP child spec for a named actor.

pool

</> 
pub fn pool(
  typed_name: registry.TypedName(msg),
  size: Int,
  initial_state: state,
  handler: fn(msg, state) -> receiver.Next(state),
) -> Result(process.Pid, actor.StartError)

Start N supervised actors, registered as name_1 .. name_N.

start

</> 
pub fn start(
  typed_name: registry.TypedName(msg),
  initial_state: state,
  handler: fn(msg, state) -> receiver.Next(state),
) -> Result(global.GlobalSubject(msg), actor.StartError)

Start a named actor.

start_registered

</> 
pub fn start_registered(
  typed_name: registry.TypedName(msg),
  initial_state: state,
  handler: fn(msg, state) -> receiver.Next(state),
) -> Result(global.GlobalSubject(msg), registry.RegisterError)

Start an actor and register it globally. Kills the actor if registration fails.

start_supervised

</> 
pub fn start_supervised(
  typed_name: registry.TypedName(msg),
  initial_state: state,
  handler: fn(msg, state) -> receiver.Next(state),
) -> Result(process.Pid, actor.StartError)

Start a supervised actor that auto-registers on (re)start.

✨ Search Document