oa_gateway_bench::scenarios::owp

Function drain_pending

Source 
async fn drain_pending(
    ws: &mut WebSocketStream<MaybeTlsStream<TcpStream>>,
    errors: &AtomicU64,
)