We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 80e4381 commit 232658aCopy full SHA for 232658a
1 file changed
src/lib/hub/actor.rs
@@ -64,7 +64,7 @@ impl HubActor {
64
let _ = response.send(drivers);
65
}
66
HubCommand::GetSender { response } => {
67
- let _ = response.send(self.bcst_sender.clone());
+ let _ = response.send(self.get_sender());
68
69
HubCommand::GetDriversStats { response } => {
70
let drivers_stats = self.get_drivers_stats().await;
@@ -129,7 +129,7 @@ impl HubActor {
129
async fn add_driver(&mut self, driver: Arc<dyn Driver>) -> Result<DriverUuid> {
130
let uuid = *driver.uuid();
131
132
- let hub_sender = self.bcst_sender.clone();
+ let hub_sender = self.get_sender();
133
134
let task = tokio::spawn({
135
let driver = driver.clone();
0 commit comments