cargo fmt
This commit is contained in:
parent
a13f5d02fa
commit
95b8562812
@ -958,11 +958,7 @@ async fn handle_connection(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn start(
|
pub fn start(cfg: Rc<Config>, restart_idle: Rc<Semaphore>, drtio_tuple: Option<DrtioTuple>) {
|
||||||
cfg: Rc<Config>,
|
|
||||||
restart_idle: Rc<Semaphore>,
|
|
||||||
drtio_tuple: Option<DrtioTuple>,
|
|
||||||
) {
|
|
||||||
task::spawn(async move {
|
task::spawn(async move {
|
||||||
let pull_id = Rc::new(RefCell::new(0u32));
|
let pull_id = Rc::new(RefCell::new(0u32));
|
||||||
loop {
|
loop {
|
||||||
|
Loading…
Reference in New Issue
Block a user