#[tokio::test]
async fn tproxy_survives_downstream_disconnect() {
    tracing_subscriber::fmt()
        .with_env_filter(EnvFilter::from_default_env())
        .init();
    let (_tp, tp_addr) = start_template_provider(None).await;
    let (_pool, pool_addr) = start_pool(Some(tp_addr)).await;
    let (_, tproxy_addr) = start_sv2_translator(pool_addr).await;

    // emulate first downstream
    let downstream_a = std::net::TcpStream::connect(tproxy_addr).unwrap();

    // emulate second downstream
    let _downstream_b = std::net::TcpStream::connect(tproxy_addr).unwrap();

    // wait a bit to make sure the TCP sockets are processed
    tokio::time::sleep(std::time::Duration::from_secs(1)).await;

    // kill downstream_a
    downstream_a.shutdown(std::net::Shutdown::Both).unwrap();
    drop(downstream_a);

    // wait a bit to make sure the TCP sockets are processed
    tokio::time::sleep(std::time::Duration::from_secs(1)).await;

    // tproxy still up
    assert!(tokio::net::TcpListener::bind(tproxy_addr).await.is_err());
}