commands

reset_stream_sink(token)

Reset the streaming sink to a previous value.

Source code in src/awesome_os/tasks/commands.py

def reset_stream_sink(token: contextvars.Token[Callable[[str], None] | None]) -> None:
    """Reset the streaming sink to a previous value."""
    _stream_sink.reset(token)

set_stream_sink(sink)

Set a per-context sink to receive streaming subprocess output lines.

Source code in src/awesome_os/tasks/commands.py

def set_stream_sink(
    sink: Callable[[str], None] | None,
) -> contextvars.Token[Callable[[str], None] | None]:
    """Set a per-context sink to receive streaming subprocess output lines."""
    return _stream_sink.set(sink)