Chronicle.Task (chronicle v0.1.2)

Task helpers that propagate the current audit context and active group.

Tasks started inside a group must be awaited before the group function returns. A task cannot append to a group after that group has closed.

Summary

async(fun)

start(fun)

start_link(fun)

wrap(fun)

@spec async((-> result)) :: Task.t() when result: term()

@spec async_stream(Enumerable.t(), (term() -> term()), keyword()) :: Enumerable.t()

@spec async_stream(
  Supervisor.supervisor(),
  Enumerable.t(),
  (term() -> term()),
  keyword()
) :: Enumerable.t()

@spec start((-> result)) :: {:ok, pid()} | {:error, term()} when result: term()

@spec start_link((-> result)) :: {:ok, pid()} | {:error, term()} when result: term()

@spec wrap((-> result)) :: (-> result) when result: term()