View Source ProcessHub.Service.Mailbox (ProcessHub v0.3.2-alpha)

The messenger service provides API functions for receiving messages from other processes.

Summary

Functions

Waits for multiple child process startup results.

Waits for multiple child process termination results.

Waits for multiple child response messages.

Receives a single child response message.

Functions

Link to this function

collect_start_results(hub_id, opts)

View Source
@spec collect_start_results(
  ProcessHub.hub_id(),
  keyword()
) :: {:ok, list()} | {:error, {list(), list()}}

Waits for multiple child process startup results.

Link to this function

collect_stop_results(hub_id, opts)

View Source
@spec collect_stop_results(
  ProcessHub.hub_id(),
  keyword()
) :: {:ok, list()} | {:error, {list(), list()}}

Waits for multiple child process termination results.

Link to this function

receive_child_resp(receivables, type, handler, error, timeout)

View Source
@spec receive_child_resp(
  [{node(), [ProcessHub.child_id()]}],
  term(),
  function(),
  term(),
  pos_integer()
) :: list()

Waits for multiple child response messages.

Link to this function

receive_response(type, handler, timeout)

View Source

Receives a single child response message.

Link to this function

receive_response(type, child_id, node, handler, timeout, error \\ nil)

View Source

Receives a single child response message.