From e6002d7076d31df3aac38f0299a6619e8fe62edb Mon Sep 17 00:00:00 2001
From: leeeon233 <leeeon233@gmail.com>
Date: Wed, 15 Mar 2023 20:43:26 +0800
Subject: [PATCH] bench: observe txn

---
 crates/loro-internal/benches/text.rs | 35 ++++++++++++++++++++++++++++
 1 file changed, 35 insertions(+)

diff --git a/crates/loro-internal/benches/text.rs b/crates/loro-internal/benches/text.rs
index e5b74fc9..cfecbb0d 100644
--- a/crates/loro-internal/benches/text.rs
+++ b/crates/loro-internal/benches/text.rs
@@ -102,6 +102,41 @@ mod run {
             })
         });
 
+        b.bench_function("B4 Observed_Per100_Txn", |b| {
+            b.iter(|| {
+                let mut loro = LoroCore::default();
+                loro.subscribe_deep(Box::new(|_| {}));
+                let mut text = loro.get_text("text");
+                let mut n = 0;
+                let mut txn = loro.transact();
+                for TextAction { pos, ins, del } in actions.iter() {
+                    if n == 100 {
+                        n = 0;
+                        drop(txn);
+                        txn = loro.transact();
+                    }
+                    n += 1;
+                    text.delete(&txn, *pos, *del).unwrap();
+                    text.insert(&txn, *pos, ins).unwrap();
+                }
+            })
+        });
+
+        b.bench_function("B4 Observed_All_Txn", |b| {
+            b.iter(|| {
+                let mut loro = LoroCore::default();
+                loro.subscribe_deep(Box::new(|_| {}));
+                let mut text = loro.get_text("text");
+                {
+                    let txn = loro.transact();
+                    for TextAction { pos, ins, del } in actions.iter() {
+                        text.delete(&txn, *pos, *del).unwrap();
+                        text.insert(&txn, *pos, ins).unwrap();
+                    }
+                }
+            })
+        });
+
         // b.sample_size(10);
         b.bench_function("B4DirectSync", |b| {
             b.iter(|| {