Struct OutputAgent

pub struct OutputAgent { /* private fields */ }

Actor-like, dedicated worker thread that handles writing to an output stream. Accepts tasks as messages, which are executed by the agent.

Note that the OutputAgent type is not meant to be Sync, it is meant to be synchronized externally, or more typically, used by one controlling thread only.

Implementations

impl OutputAgent

pub fn start_with_provider<OUT, OUT_P>( msg_writer_provider: OUT_P, ) -> OutputAgent

where OUT: MessageWriter + 'static, OUT_P: FnOnce() -> OUT + Send + 'static,

pub fn start<AGENT_RUNNER>(agent_runner: AGENT_RUNNER) -> OutputAgent

where AGENT_RUNNER: AgentRunnable + Send + 'static,

pub fn is_shutdown(&self) -> bool

pub fn try_submit_task( &self, task: OutputAgentTask, ) -> Result<(), SendError<OutputAgentMessage>>

pub fn submit_task(&self, task: OutputAgentTask)

pub fn request_shutdown(&mut self)

pub fn shutdown_and_soft_join(&mut self) -> Result<()>

pub fn shutdown_and_join(&mut self)

Trait Implementations

impl Drop for OutputAgent

fn drop(&mut self)

Executes the destructor for this type.