Vibe.Command.Streaming (vibe v0.2.2)

Copy Markdown View Source

Streaming output capture for long-running commands.

Summary

Functions

callback_from_process()
current_session_id()
track(session_id, pid)
untrack(session_id, pid)
with_eval_session(session_id, fun)

Functions

callback_from_process()

@spec callback_from_process() :: (binary() -> :ok) | nil

current_session_id()

@spec current_session_id() :: String.t() | nil

track(session_id, pid)

@spec track(String.t() | nil, pid()) :: :ok

untrack(session_id, pid)

@spec untrack(String.t() | nil, pid()) :: :ok

with_eval_session(session_id, fun)

@spec with_eval_session(String.t() | nil, (-> term())) :: term()