Struct safe_async_scoped::Scope

pub struct Scope<'env> { /* fields omitted */ }

An opaque utility for spawning local tasks that has access to the scope that Scope has access to.

Example

let listener = Async::new(TcpListener::bind("127.0.0.1:8080").unwrap()).unwrap();
let lala = String::from("hello");
{
    let scope = Scope::new();
    scope
        .start(async {
            loop {
                let (client, _) = listener.accept().await.unwrap();
                scope.spawn(async {
                    handle(client, &lala).await;
                });
            }
        })
        .await;
}

Implementations

impl<'env> Scope<'env>

pub fn new() -> Self

Creates a new scope.

pub fn spawn<F: Future<Output = ()> + 'env>(&self, fut: F)

Schedules a future to be spawned onto the scope.

pub async fn start<'future, 'scope: 'future>(
    &'scope self,
    fut: impl Future<Output = ()> + 'future
)

Starts a context in which scoped tasks can be spawned. When fut resolves, all spawned tasks are forcibly dropped.

Trait Implementations

impl<'env> Default for Scope<'env>

fn default() -> Self

Returns the "default value" for a type.