Remove unused field

crates/librqbit/src/session.rs

@@ -972,7 +972,6 @@ impl Session {
         builder
             .overwrite(opts.overwrite)
             .spawner(self.spawner)
-            .cancellation_token(cancellation_token.clone())
             .trackers(trackers)
             .peer_id(self.peer_id);
 
@@ -1101,7 +1100,7 @@ impl Session {
     }
 
     pub fn unpause(&self, handle: &ManagedTorrentHandle) -> anyhow::Result<()> {
-        let token = handle.cancellation_token.child_token();
+        let token = self.cancellation_token.child_token();
         let peer_rx = self.make_peer_rx(
             handle.info_hash(),
             handle.info().trackers.clone().into_iter().collect(),

crates/librqbit/src/torrent_state/mod.rs

@@ -91,7 +91,6 @@ pub struct ManagedTorrentInfo {
 
 pub struct ManagedTorrent {
     pub info: Arc<ManagedTorrentInfo>,
-    pub cancellation_token: CancellationToken,
     pub(crate) only_files: Option<Vec<usize>>,
     locked: RwLock<ManagedTorrentLocked>,
 }
@@ -428,7 +427,6 @@ pub struct ManagedTorrentBuilder {
     peer_id: Option<Id20>,
     overwrite: bool,
     spawner: Option<BlockingSpawner>,
-    cancellation_token: Option<CancellationToken>,
 }
 
 impl ManagedTorrentBuilder {
@@ -449,15 +447,9 @@ impl ManagedTorrentBuilder {
             trackers: Default::default(),
             peer_id: None,
             overwrite: false,
-            cancellation_token: None,
         }
     }
 
-    pub fn cancellation_token(&mut self, token: CancellationToken) -> &mut Self {
-        self.cancellation_token = Some(token);
-        self
-    }
-
     pub fn only_files(&mut self, only_files: Vec<usize>) -> &mut Self {
         self.only_files = Some(only_files);
         self
@@ -498,7 +490,7 @@ impl ManagedTorrentBuilder {
         self
     }
 
-    pub(crate) fn build(mut self, span: tracing::Span) -> anyhow::Result<ManagedTorrentHandle> {
+    pub(crate) fn build(self, span: tracing::Span) -> anyhow::Result<ManagedTorrentHandle> {
         let lengths = Lengths::from_torrent(&self.info)?;
         let info = Arc::new(ManagedTorrentInfo {
             span,
@@ -525,7 +517,6 @@ impl ManagedTorrentBuilder {
             locked: RwLock::new(ManagedTorrentLocked {
                 state: ManagedTorrentState::Initializing(initializing),
             }),
-            cancellation_token: self.cancellation_token.take().unwrap_or_default(),
             info,
         }))
     }