async fn run_tx_queue<T: TapT>(
    queue: Queue,
    tap: T,
    kick_evt: EventAsync,
    stop_rx: Receiver<()>
) -> Queue