Skip to content

Commit 9a75ca1

Browse files
committed
Update spirc shuffle command for tokio migration
1 parent 9d5ac1b commit 9a75ca1

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

connect/src/spirc.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -352,7 +352,7 @@ impl Spirc {
352352
let _ = self.commands.send(SpircCommand::Shutdown);
353353
}
354354
pub fn shuffle(&self) {
355-
let _ = self.commands.unbounded_send(SpircCommand::Shuffle);
355+
let _ = self.commands.send(SpircCommand::Shuffle);
356356
}
357357
}
358358

@@ -525,7 +525,6 @@ impl SpircTask {
525525
}
526526
SpircCommand::Shuffle => {
527527
CommandSender::new(self, MessageType::kMessageTypeShuffle).send();
528-
self.commands.close();
529528
}
530529
}
531530
}

0 commit comments

Comments
 (0)