INNER CODE UNIT · Rust

Ok

HemantKArya/BloomeeTunes · rust/src/api/downloader/mod.rs:207

            if let Ok(mut guard) = self.tasks.write() {
                guard.insert(p.task_id.clone(), task);
            }
        }

        self.persist_manifest();

        for snapshot in &snapshots {
            match snapshot.state {
                DownloadTaskState::CompletedPendingAck => {
                    self.emit(DownloadManagerEvent::TaskCompletedPendingAck(snapshot.clone()));
                }
                _ => self.emit(DownloadManagerEvent::TaskUpdated(snapshot.clone())),
            }
        }
        self.emit(DownloadManagerEvent::RecoverySummary { restored, cleaned });

        Ok(snapshots)

View source record →