move all automerge references to document

2 files changed, 1 insertions, 20 deletions

diff --git a/src/state/mod.rs b/src/state/mod.rs
index 673bd56..8ac1124 100644
--- a/src/state/mod.rs
+++ b/src/state/mod.rs
@@ -394,25 +394,6 @@ impl AppState {
         .expect("document read task panicked")
     }
 
-    /// Mutates the document on the blocking pool.
-    pub(crate) async fn write_doc<T>(
-        &self,
-        f: impl FnOnce(&mut Document) -> T + Send + 'static,
-    ) -> T
-    where
-        T: Send + 'static,
-    {
-        let doc = Arc::clone(&self.doc);
-        tokio::task::spawn_blocking(move || {
-            let mut replica = doc.blocking_write();
-            let out = f(&mut replica.doc);
-            replica.refresh_heads();
-            out
-        })
-        .await
-        .expect("document write task panicked")
-    }
-
     /// Mutates the document on the blocking pool as one change, then
     /// publishes it. Write and notification run in the same blocking task, so a
     /// cancelled request can't leave a committed write unannounced.
diff --git a/src/state/session.rs b/src/state/session.rs
index bf5c83f..7305c58 100644
--- a/src/state/session.rs
+++ b/src/state/session.rs
@@ -245,7 +245,7 @@ impl SyncSession {
     /// For the simulator's dump: the peer's heads as Automerge knows them, and whether
     /// it thinks a message is in flight.
     #[cfg(test)]
-    pub(crate) fn automerge_view(&self) -> (Option<&[crate::document::ChangeHash]>, bool) {
+    pub(crate) fn sync_view(&self) -> (Option<&[crate::document::ChangeHash]>, bool) {
         (self.state.their_heads.as_deref(), self.state.in_flight)
     }