Struct StdinSource 

pub struct StdinSource { /* private fields */ }

Reads events from stdin, one per line.

Reading happens on a dedicated OS thread (std::thread) that forwards each line over a bounded channel, rather than via tokio::io::stdin(). tokio::io::stdin() is implemented with an ordinary blocking read on a runtime-managed thread that cannot be cancelled; when no input is pending, that read parks until the next line or EOF and the Tokio runtime waits for it during shutdown. That makes the daemon hang on Ctrl+C / SIGTERM until more input arrives (see the tokio::io::stdin docs). Because a plain std::thread is not a runtime blocking task, the runtime does not wait for it at shutdown, so the daemon exits promptly even with an idle stdin.

Implementations

impl StdinSource

pub fn new() -> Self

Trait Implementations

impl Default for StdinSource

fn default() -> Self

Returns the “default value” for a type.

impl EventSource for StdinSource

async fn recv(&mut self) -> Option<RawEvent>

Receive the next event with its ack token. Returns None when the source is exhausted or shutting down.