mirror of
https://github.com/mat-1/azalea.git
synced 2025-08-02 14:26:04 +00:00
fix panics in wait_until_goto_target_reached
This commit is contained in:
parent
77f9d929b6
commit
a05a0b709c
1 changed files with 6 additions and 1 deletions
|
@ -40,6 +40,7 @@ use futures_lite::future;
|
||||||
use goals::BlockPosGoal;
|
use goals::BlockPosGoal;
|
||||||
use parking_lot::RwLock;
|
use parking_lot::RwLock;
|
||||||
use rel_block_pos::RelBlockPos;
|
use rel_block_pos::RelBlockPos;
|
||||||
|
use tokio::sync::broadcast::error::RecvError;
|
||||||
use tracing::{debug, error, info, trace, warn};
|
use tracing::{debug, error, info, trace, warn};
|
||||||
|
|
||||||
pub use self::debug::PathfinderDebugParticles;
|
pub use self::debug::PathfinderDebugParticles;
|
||||||
|
@ -253,7 +254,11 @@ impl PathfinderClientExt for azalea_client::Client {
|
||||||
let mut tick_broadcaster = self.get_tick_broadcaster();
|
let mut tick_broadcaster = self.get_tick_broadcaster();
|
||||||
while !self.is_goto_target_reached() {
|
while !self.is_goto_target_reached() {
|
||||||
// check every tick
|
// check every tick
|
||||||
tick_broadcaster.recv().await.unwrap();
|
match tick_broadcaster.recv().await {
|
||||||
|
Ok(_) => (),
|
||||||
|
Err(RecvError::Closed) => return,
|
||||||
|
Err(err) => eprintln!("{err}"),
|
||||||
|
};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue