Struct ShutdownToken 

pub struct ShutdownToken(Receiver<()>);

Shutdown signal handed to a worker at spawn time. Workers select! between their input source and &mut self.0; reducer-task exit drops the matched Sender<()> and the receiver resolves with Err(RecvError). Workers treat any resolution as “shutdown” and exit cleanly.

Tuple Fields

0: Receiver<()>

Implementations

impl ShutdownToken

pub fn into_inner(self) -> Receiver<()>

Unwrap to the inner Receiver<()> for direct use in select!. The idiomatic pattern is:

let mut shutdown = token.into_inner();
loop {
    tokio::select! {
        _ = &mut shutdown => return,
        msg = input.recv() => { ... }
    }
}