fix: better naming

n0-computer · Sep 20, 2023 · 49e2d40 · 49e2d40
1 parent c6a34a8
commit 49e2d40
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/iroh/src/sync_engine/live.rs b/iroh/src/sync_engine/live.rs
@@ -595,13 +595,13 @@ impl<S: store::Store, B: baomap::Store> Actor<S, B> {
     }
 
     async fn start_sync(&mut self, namespace: NamespaceId, peers: Vec<PeerSource>) -> Result<()> {
-        self.ensure_subscription(namespace)?;
+        self.ensure_open(namespace)?;
         self.syncing_replicas.insert(namespace);
         self.join_peers(namespace, peers).await?;
         Ok(())
     }
 
-    fn ensure_subscription(&mut self, namespace: NamespaceId) -> anyhow::Result<()> {
+    fn ensure_open(&mut self, namespace: NamespaceId) -> anyhow::Result<()> {
         if !self.open_replicas.contains(&namespace) {
             let Some(replica) = self.replica_store.open_replica(&namespace)? else {
                 bail!("Replica not found");
@@ -647,7 +647,7 @@ impl<S: store::Store, B: baomap::Store> Actor<S, B> {
         namespace: NamespaceId,
         cb: OnLiveEventCallback,
     ) -> anyhow::Result<RemovalToken> {
-        self.ensure_subscription(namespace)?;
+        self.ensure_open(namespace)?;
         let subs = self.event_subscriptions.entry(namespace).or_default();
         let removal_id = self
             .event_removal_id