fix fair queue

This commit is contained in:
Conrad Ludgate
2024-07-29 16:12:44 +01:00
parent 300a43db5c
commit c766021d5f

View File

@@ -112,7 +112,11 @@ where
bucket_width,
},
state: Mutex::new(LeakyBucketState::new(end)),
queue: fair.then(Notify::new),
queue: fair.then(|| {
let queue = Notify::new();
queue.notify_one();
queue
}),
};
Inner {