diff options
| author | mat <git@matdoes.dev> | 2023-12-05 10:55:20 -0600 |
|---|---|---|
| committer | mat <git@matdoes.dev> | 2023-12-05 10:55:20 -0600 |
| commit | ea3e8600126a58f5666d50fbf70dff8209d8979f (patch) | |
| tree | 314681ced884d549f5c3d530ee2f8f1cd6a47132 /azalea/src/swarm | |
| parent | 421d8ce2c837e3140d8f866e63032c277b31a413 (diff) | |
| download | azalea-drasl-ea3e8600126a58f5666d50fbf70dff8209d8979f.tar.xz | |
make start return never
Diffstat (limited to 'azalea/src/swarm')
| -rw-r--r-- | azalea/src/swarm/mod.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/azalea/src/swarm/mod.rs b/azalea/src/swarm/mod.rs index d485eb30..1c89cdbe 100644 --- a/azalea/src/swarm/mod.rs +++ b/azalea/src/swarm/mod.rs @@ -292,7 +292,7 @@ where /// that implements `TryInto<ServerAddress>`. /// /// [`ServerAddress`]: azalea_protocol::ServerAddress - pub async fn start(self, address: impl TryInto<ServerAddress>) -> Result<(), StartError> { + pub async fn start(self, address: impl TryInto<ServerAddress>) -> Result<!, StartError> { assert_eq!( self.accounts.len(), self.states.len(), @@ -351,7 +351,7 @@ where let accounts = self.accounts.clone(); let states = self.states.clone(); - let join_task = tokio::spawn(async move { + tokio::spawn(async move { if let Some(join_delay) = join_delay { // if there's a join delay, then join one by one for (account, state) in accounts.iter().zip(states) { @@ -412,9 +412,9 @@ where } } - join_task.abort(); - - Ok(()) + unreachable!( + "bots_rx.recv() should never be None because the bots_tx channel is never closed" + ); } } |
