Skip to content

Commit 55ddf3e

Browse files
committed
fix: doctests
1 parent d10b7cd commit 55ddf3e

File tree

2 files changed

+19
-15
lines changed

2 files changed

+19
-15
lines changed

src/abstract.rs

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -320,7 +320,7 @@ pub trait AbstractTree {
320320
/// use lsm_tree::{AbstractTree, Config, Tree};
321321
///
322322
/// let folder = tempfile::tempdir()?;
323-
/// let tree = Config::new(folder, Default::default()).open()?;
323+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
324324
///
325325
/// assert_eq!(tree.len(0, None)?, 0);
326326
/// tree.insert("1", "abc", 0);
@@ -355,7 +355,7 @@ pub trait AbstractTree {
355355
/// # let folder = tempfile::tempdir()?;
356356
/// use lsm_tree::{AbstractTree, Config, Tree};
357357
///
358-
/// let tree = Config::new(folder, Default::default()).open()?;
358+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
359359
/// assert!(tree.is_empty(0, None)?);
360360
///
361361
/// tree.insert("a", "abc", 0);
@@ -381,7 +381,7 @@ pub trait AbstractTree {
381381
/// # use lsm_tree::{AbstractTree, Config, Tree};
382382
/// #
383383
/// # let folder = tempfile::tempdir()?;
384-
/// let tree = Config::new(folder, Default::default()).open()?;
384+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
385385
///
386386
/// tree.insert("1", "abc", 0);
387387
/// tree.insert("3", "abc", 1);
@@ -417,7 +417,7 @@ pub trait AbstractTree {
417417
/// # use lsm_tree::{AbstractTree, Config, Tree};
418418
/// #
419419
/// # let folder = tempfile::tempdir()?;
420-
/// # let tree = Config::new(folder, Default::default()).open()?;
420+
/// # let tree = Config::new(folder, Default::default(), Default::default()).open()?;
421421
/// #
422422
/// tree.insert("1", "abc", 0);
423423
/// tree.insert("3", "abc", 1);
@@ -451,7 +451,7 @@ pub trait AbstractTree {
451451
/// # let folder = tempfile::tempdir()?;
452452
/// use lsm_tree::{AbstractTree, Config, Tree};
453453
///
454-
/// let tree = Config::new(folder, Default::default()).open()?;
454+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
455455
/// tree.insert("a", "my_value", 0);
456456
///
457457
/// let size = tree.size_of("a", 1)?.unwrap_or_default();
@@ -476,7 +476,7 @@ pub trait AbstractTree {
476476
/// # let folder = tempfile::tempdir()?;
477477
/// use lsm_tree::{AbstractTree, Config, Tree};
478478
///
479-
/// let tree = Config::new(folder, Default::default()).open()?;
479+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
480480
/// tree.insert("a", "my_value", 0);
481481
///
482482
/// let item = tree.get("a", 1)?;
@@ -498,7 +498,7 @@ pub trait AbstractTree {
498498
/// # let folder = tempfile::tempdir()?;
499499
/// # use lsm_tree::{AbstractTree, Config, Tree};
500500
/// #
501-
/// let tree = Config::new(folder, Default::default()).open()?;
501+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
502502
/// assert!(!tree.contains_key("a", 0)?);
503503
///
504504
/// tree.insert("a", "abc", 0);
@@ -526,7 +526,7 @@ pub trait AbstractTree {
526526
/// # let folder = tempfile::tempdir()?;
527527
/// use lsm_tree::{AbstractTree, Config, Tree};
528528
///
529-
/// let tree = Config::new(folder, Default::default()).open()?;
529+
/// let tree = Config::new(folder, Default::default(), Default::default()).open()?;
530530
/// tree.insert("a", "abc", 0);
531531
/// #
532532
/// # Ok::<(), lsm_tree::Error>(())
@@ -552,7 +552,7 @@ pub trait AbstractTree {
552552
/// # let folder = tempfile::tempdir()?;
553553
/// # use lsm_tree::{AbstractTree, Config, Tree};
554554
/// #
555-
/// # let tree = Config::new(folder, Default::default()).open()?;
555+
/// # let tree = Config::new(folder, Default::default(), Default::default()).open()?;
556556
/// tree.insert("a", "abc", 0);
557557
///
558558
/// let item = tree.get("a", 1)?.expect("should have item");
@@ -586,7 +586,7 @@ pub trait AbstractTree {
586586
/// # let folder = tempfile::tempdir()?;
587587
/// # use lsm_tree::{AbstractTree, Config, Tree};
588588
/// #
589-
/// # let tree = Config::new(folder, Default::default()).open()?;
589+
/// # let tree = Config::new(folder, Default::default(), Default::default()).open()?;
590590
/// tree.insert("a", "abc", 0);
591591
///
592592
/// let item = tree.get("a", 1)?.expect("should have item");

src/seqno.rs

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,21 +21,25 @@ use std::sync::{
2121
/// # let path = tempfile::tempdir()?;
2222
///
2323
/// let seqno = SequenceNumberCounter::default();
24+
/// let visible_seqno = SequenceNumberCounter::default();
2425
///
25-
/// let tree = Config::new(path, seqno.clone()).open()?;
26+
/// let tree = Config::new(path, seqno.clone(), visible_seqno.clone()).open()?;
2627
///
2728
/// // Do some inserts...
28-
/// tree.insert("a".as_bytes(), "abc", seqno.next());
29-
/// tree.insert("b".as_bytes(), "abc", seqno.next());
30-
/// tree.insert("c".as_bytes(), "abc", seqno.next());
29+
/// for k in [b"a", b"b", b"c"] {
30+
/// let batch_seqno = seqno.next();
31+
/// tree.insert(k, "abc", batch_seqno);
32+
/// visible_seqno.fetch_max(batch_seqno + 1);
33+
/// }
3134
///
3235
/// // Create a batch
3336
/// let batch_seqno = seqno.next();
3437
/// tree.remove("a".as_bytes(), batch_seqno);
3538
/// tree.remove("b".as_bytes(), batch_seqno);
3639
/// tree.remove("c".as_bytes(), batch_seqno);
40+
/// visible_seqno.fetch_max(batch_seqno + 1);
3741
/// #
38-
/// # assert!(tree.is_empty(batch_seqno + 1, None)?);
42+
/// # assert!(tree.is_empty(visible_seqno.get(), None)?);
3943
/// # Ok::<(), lsm_tree::Error>(())
4044
/// ```
4145
#[derive(Clone, Default, Debug)]

0 commit comments

Comments
 (0)