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

use crate::upgrade::Connection;

/// The sending half of a channel to send an upgraded connection.

///

/// Unlike `async_channel::Sender` the `send` method on this type can only be

/// called once, and cannot be cloned. That's because only a single instance of

/// `Connection` should be created.

#[derive(Debug)]
pub struct Sender {
    sender: async_channel::Sender<Connection>,
}

impl Sender {
    /// Create a new instance of `Sender`.

    #[doc(hidden)]
    pub fn new(sender: async_channel::Sender<Connection>) -> Self {
        Self { sender }
    }

    /// Send a `Trailer`.

    ///

    /// The channel will be consumed after having sent trailers.

    pub async fn send(self, trailers: Connection) {
        let _ = self.sender.send(trailers).await;
    }
}