Struct RunningTopology 

pub struct RunningTopology { /* private fields */ }

A running topology.

Implementations

impl RunningTopology

pub async fn wait_for_unexpected_finish(&mut self)

Waits for any spawned component to unexpectedly finish.

This can be used in a loop to determine if any component has unexpectedly finished before shutdown was initiated, which usually represents an error or bug with the component.

pub async fn shutdown(self) -> Result<(), GenericError>

Triggers the topology to shutdown, waiting until all components have stopped.

This will wait indefinitely for all components to stop. If graceful shutdown with an upper bound is desired, use shutdown_with_timeout instead.

Errors

If the topology fails to shutdown cleanly due to an error in a component, an error will be returned.

pub async fn shutdown_with_timeout( self, timeout: Duration, ) -> Result<(), GenericError>

Triggers the topology to shutdown, waiting until all components have stopped or the timeout has elapsed.

Errors

If the topology fails to shutdown cleanly, either due to an error in a component or the timeout being reached, an error will be returned.