Update app.rs

This commit is contained in:
Koranir 2024-10-23 11:35:10 +11:00
parent 2871309f04
commit f42133bba4

View file

@ -4114,19 +4114,22 @@ impl Application for App {
]; ];
for (key, mounter) in MOUNTERS.iter() { for (key, mounter) in MOUNTERS.iter() {
let key = *key; subscriptions.push(
subscriptions.push(mounter.subscription().map(move |mounter_message| { mounter.subscription().with(*key).map(
match mounter_message { |(key, mounter_message)| match mounter_message {
MounterMessage::Items(items) => Message::MounterItems(key, items), MounterMessage::Items(items) => Message::MounterItems(key, items),
MounterMessage::MountResult(item, res) => Message::MountResult(key, item, res), MounterMessage::MountResult(item, res) => {
MounterMessage::NetworkAuth(uri, auth, auth_tx) => { Message::MountResult(key, item, res)
Message::NetworkAuth(key, uri, auth, auth_tx) }
} MounterMessage::NetworkAuth(uri, auth, auth_tx) => {
MounterMessage::NetworkResult(uri, res) => { Message::NetworkAuth(key, uri, auth, auth_tx)
Message::NetworkResult(key, uri, res) }
} MounterMessage::NetworkResult(uri, res) => {
} Message::NetworkResult(key, uri, res)
})); }
},
),
);
} }
if !self.pending_operations.is_empty() { if !self.pending_operations.is_empty() {