Struct Flushers 

pub struct Flushers(JoinSet<()>);

The handle over one signal’s flusher shards: what a single JoinHandle meant when there was one of them, kept true now that there are several.

Awaiting it resolves when every shard has stopped; abort — test-only, see below — stops them all where they stand. A JoinSet and not a task that awaits a Vec of handles, because that shape gets the second half wrong: aborting such a task drops only its own future, so the shards keep running, and a shard that outlives the node it belonged to watches its senders drop, reads that as a graceful close, and seals a block — under a sequence, and into a staging directory, that the successor node is already using.

Tuple Fields

0: JoinSet<()>

Trait Implementations

impl Drop for Flushers

Dropping the handle detaches, as dropping a JoinHandle does — a JoinSet on its own would abort instead. Read-only test harnesses build a node and keep only the parts they query; turning that into “and stop ingesting” would be a trap, and every caller that means to stop has one of the two ways to say so above.

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Future for Flushers

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Ready once the set has drained. Unlike a JoinHandle this is safe to poll again afterwards — an emptied set answers Ready forever — which is what lets main await a handle first_stopped may already have run to completion.

type Output = Result<(), JoinError>

The type of value produced on completion.