johndotpub

use std::time::Duration;
use tokio_stream::StreamExt as _ ;
use axum::body::Bytes;
use futures::{stream, StreamExt};
use axum::{body::Body, routing::get, Router};
use std::net::SocketAddr;
use tokio::net::TcpListener;

#[tokio::main]
async fn main() -> anyhow::Result<()> {