s2n-quic-dc 0.88.0

Internal crate used by s2n-quic
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

use crate::{
    event,
    stream::{recv, send},
};
use bach::{ext::*, time::timeout};

pub use bach::runtime::Handle;

impl<Sub> super::Handle<Sub> for Handle
where
    Sub: event::Subscriber,
{
    #[inline]
    fn spawn_recv_shutdown(&self, shutdown: recv::application::Shutdown<Sub>) {
        self.spawn(
            async move {
                // Note: Must be created inside spawn() since ambient runtime is otherwise not
                // guaranteed and will cause a panic on the timeout future construction.
                // make sure the task doesn't hang around indefinitely
                timeout(core::time::Duration::from_secs(1), shutdown).await
            }
            .primary(),
        );
    }

    #[inline]
    fn spawn_send_shutdown(&self, shutdown: send::application::Shutdown<Sub>) {
        self.spawn(
            async move {
                // Note: Must be created inside spawn() since ambient runtime is otherwise not
                // guaranteed and will cause a panic on the timeout future construction.
                // make sure the task doesn't hang around indefinitely
                timeout(core::time::Duration::from_secs(1), shutdown).await
            }
            .primary(),
        );
    }
}