API Reference Grains v1.6.0


Grains describes data flow as a graph with interchangeable parts.

A %Bread{} is the compiled version of Recipe plus Grains that allow the Supervisor to run the processes and wire them correctly.

Debug version of Grains.Timer.

A Recipe describes the data flow between the processes.

Support functions to simplify testing.

A grain to forward messages downstream and cache the last value it received.

A grain which holds a constant value.

A grain to forward messages downstream.

A grain to eat incoming messages without any further processing.

A grain to pull message and forward pushed messages to a subscribing process.

This is a wrapper around :erlang.trace/3 adapted to trace the sending and receiving push/pull messages in grains. The Trace server has to be started before it can be used, either directly with Trace.start_link/1 or with start_supervised!(Trace) in tests.

A grain to transform messages and push them further along.

Small function that help with debugging and testing.

A periodic timer.