async fn drain_subscriber(
ws: WebSocketStream<MaybeTlsStream<TcpStream>>,
clock: Arc<SeqClock>,
samples: Arc<Mutex<Vec<u64>>>,
received: Arc<AtomicU64>,
errors: Arc<AtomicU64>,
unmatched: Arc<AtomicU64>,
warmup_ns: u64,
)