fn main()

in http/get_simple/rs/server/src/main.rs [107:135]


fn main() -> Result<()> {
    // Configure tracing subscriber.
    tracing_subscriber::fmt()
        .with_span_events(FmtSpan::CLOSE)
        .init();

    // Generate random data.
    let _ = Lazy::force(&DATA);

    // Start listening.
    let bind_addr = SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), 8008);
    let listener = TcpListener::bind(bind_addr)?;
    info!(%bind_addr, "Listening");

    // Handle incoming connections.
    loop {
        match listener.accept() {
            Ok((stream, remote_peer)) => {
                thread::spawn(move || {
                    info_span!("Writing Arrow IPC stream", %remote_peer)
                        .in_scope(|| get_simple(stream))
                });
            }
            Err(error) => {
                error!(%error, "Connection failed");
            }
        }
    }
}