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

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

Summary

Functions

Waits for multiple child response messages.

Receives a single child response message.

Waits for multiple child process startup results.

Waits for multiple child process termination results.

Functions

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.

Link to this function

receive_start_resp(receivables, opts)

View Source
@spec receive_start_resp(
  [{node(), [ProcessHub.child_id()]}],
  keyword()
) :: {:ok, list()} | {:error, list()}

Waits for multiple child process startup results.

Link to this function

receive_stop_resp(receivables, opts)

View Source
@spec receive_stop_resp(
  [{node(), [ProcessHub.child_id()]}],
  keyword()
) :: {:ok, list()} | {:error, list()}

Waits for multiple child process termination results.