Function handle_conn

async fn handle_conn(
    stream: TcpStream,
    conn_id: u64,
    state: Arc<Mutex<BrokerState>>,
    shutdown: CancellationToken,
    tls: Option<ServerTls>,
) -> Result<(), ()>

Reads frames until the peer closes or shutdown fires, then drops this connection’s subscriptions.