volga 0.9.1

Easy & Fast Web Framework for Rust
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

//! HTTP Server tools

use crate::app::{AppEnv, scope::Scope};
use hyper::rt::{Read, Write};
use std::net::SocketAddr;
use std::sync::Weak;

#[cfg(all(feature = "http1", not(feature = "http2")))]
pub(super) mod http1;
#[cfg(any(
    all(feature = "http1", feature = "http2"),
    all(feature = "http2", not(feature = "http1"))
))]
pub(super) mod http2;

pub(super) struct Server<I: Read + Write + Unpin> {
    io: I,
    peer_addr: SocketAddr,
}

impl<I: Send + Read + Write + Unpin + 'static> Server<I> {
    #[inline]
    pub(super) fn new(io: I, peer_addr: SocketAddr) -> Self {
        Self { io, peer_addr }
    }

    #[inline]
    pub(super) async fn serve(self, env: Weak<AppEnv>) {
        if let Some(instance) = env.upgrade() {
            let scope = Scope::new(env, self.peer_addr);
            self.serve_core(scope, instance).await;
        } else {
            #[cfg(feature = "tracing")]
            tracing::warn!("app instance could not be upgraded; aborting...");
        }
    }
}