async fn flusher<B: SignalBuilder>( rx: Receiver<Job<B::Request>>, asks: Receiver<Sender<Option<Arc<Open>>>>, cfg: Arc<Config>, open_slot: Shard, shard: usize, shards: usize, resume: u64, )