Struct trillium_tokio::Stopper

pub struct Stopper(/* private fields */);

This struct provides a synchronized mechanism for canceling Futures and Streams.

Stoppers are cheap to clone.

A clone of the Stopper can be awaited and will be pending until the Stopper is stopped. If the Stopper is stopped before it is awaited, it will be ready immediately.

Implementations

impl Stopper

pub fn new() -> Stopper

Initialize a stopper that is not yet stopped and that has zero registered wakers. Any clone of this stopper represents the same internal state. This is identical to Stopper::default()

pub fn stop(&self)

Stop all futures and streams that have been registered to this Stopper or any clone representing the same initial stopper.

pub fn is_stopped(&self) -> bool

Returns whether this stopper (or any clone of it) has been stopped.

pub fn stop_stream<S>(&self, stream: S) -> StreamStopper<S>

where S: Stream,

This function returns a new stream which will poll None (indicating a completed stream) when this Stopper has been stopped. The Stream’s Item is unchanged.

pub fn stop_future<F>(&self, future: F) -> FutureStopper<F>

where F: Future,

This function returns a Future which wraps the provided future and stops it when this Stopper has been stopped. Note that the Output of the returned future is wrapped with an Option. If the future resolves to None, that indicates that it was stopped instead of polling to completion.

Trait Implementations

impl Clone for Stopper

fn clone(&self) -> Stopper

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Stopper

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for Stopper

fn default() -> Stopper

Returns the “default value” for a type.

impl From<Stopped> for Stopper

fn from(value: Stopped) -> Stopper

Converts to this type from the input type.

impl From<StopperInner> for Stopper

fn from(value: StopperInner) -> Stopper

Converts to this type from the input type.

impl IntoFuture for Stopper

type Output = ()

The output that the future will produce on completion.

type IntoFuture = Stopped

Which kind of future are we turning this into?

fn into_future(self) -> <Stopper as IntoFuture>::IntoFuture

Creates a future from a value.