flo_rope 0.2.0

An attributed and streaming implementation of the rope data structure
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

use crate::*;

use std::rc::*;
use std::cell::*;

#[test]
fn push_before_remove_middle() {
    let has_changed = Rc::new(RefCell::new(false));
    let set_changed = Rc::clone(&has_changed);

    let rope        = AttributedRope::<_, ()>::from(vec![1, 2, 3, 4, 5, 6, 7, 8]);
    let mut rope    = PushBeforeRope::from(rope, move |action| { assert!(action == &RopeAction::Replace(1..7, vec![])); (*set_changed.borrow_mut()) = true; });

    rope.replace(1..7, vec![]);

    assert!(*has_changed.borrow());
    assert!(rope.read_cells(0..8).cloned().collect::<Vec<_>>() == vec![1, 8]);
    assert!(rope.len() == 2);
}

#[test]
fn push_before_after_middle() {
    let has_changed = Rc::new(RefCell::new(false));
    let set_changed = Rc::clone(&has_changed);

    let rope        = AttributedRope::<_, ()>::from(vec![1, 2, 3, 4, 5, 6, 7, 8]);
    let mut rope    = PushAfterRope::from(rope, move |action| { assert!(action == RopeAction::Replace(1..7, vec![])); (*set_changed.borrow_mut()) = true; });

    rope.replace(1..7, vec![]);

    assert!(*has_changed.borrow());
    assert!(rope.read_cells(0..8).cloned().collect::<Vec<_>>() == vec![1, 8]);
    assert!(rope.len() == 2);
}

#[test]
fn pull_basic_change() {
    let mut rope = PullRope::from(AttributedRope::<u8, ()>::new(), || {});

    rope.replace(0..0, vec![1, 2, 3]);

    let pulled = rope.pull_changes().collect::<Vec<_>>();
    assert!(pulled == vec![RopeAction::Replace(0..0, vec![1, 2, 3])]);
}

#[test]
fn clear_after_pull() {
    let mut rope = PullRope::from(AttributedRope::<u8, ()>::new(), || {});

    rope.replace(0..0, vec![1, 2, 3]);

    let _       = rope.pull_changes();
    let pulled  = rope.pull_changes().collect::<Vec<_>>();
    assert!(pulled == vec![]);
}

#[test]
fn pull_overlapping_changes() {
    let mut rope = PullRope::from(AttributedRope::<u8, ()>::new(), || {});

    rope.replace(0..0, vec![1, 2, 3]);
    rope.replace(1..2, vec![1, 2, 3]);

    let pulled = rope.pull_changes().collect::<Vec<_>>();
    assert!(pulled == vec![RopeAction::Replace(0..0, vec![1, 1, 2, 3, 3])]);
}

#[test]
fn notify_attribute_changes() {
    let mut rope = PullRope::from(AttributedRope::<u8, ()>::new(), || {});

    rope.replace(0..0, vec![1, 2, 3]);
    rope.replace_attributes(1..2, vec![1, 2, 3], ());

    let pulled = rope.pull_changes().collect::<Vec<_>>();
    assert!(pulled == vec![RopeAction::ReplaceAttributes(0..0, vec![1, 1, 2, 3, 3], ())]);
}

#[test]
fn concat_str() {
    // Two pull ropes to represent the left and right-hand side of the stream
    let mut lhs             = PullRope::from(AttributedRope::<u8, ()>::new(), || {});
    let mut rhs             = PullRope::from(AttributedRope::<u8, ()>::new(), || {});

    // An attributed rope to contain the results of the operation
    let mut concatenated    = AttributedRope::<u8, ()>::new();

    // A concatenator to join the edits to the LHS and RHS of the two ropes
    let mut concatenator    = RopeConcatenator::new();

    // LHS: 'Hello,'
    lhs.replace(0..0, "Hello,".bytes());
    concatenator.send_left(lhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Hello,");

    // RHS: ' World'
    rhs.replace(0..0, " World".bytes());
    concatenator.send_right(rhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Hello, World");

    // LHS: replace 'Hello' with 'Goodbye'
    lhs.replace(0..5, "Goodbye".bytes());
    concatenator.send_left(lhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Goodbye, World");

    // RHS: replace 'orl' with 'ilfre'
    rhs.replace(2..5, "ilfre".bytes());
    concatenator.send_right(rhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Goodbye, Wilfred");

    // LHS: replace 'bye' with ' day'
    lhs.replace(4..7, " day".bytes());
    concatenator.send_left(lhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Good day, Wilfred");

    // RHS: replace 'Wil' with 'Al'
    rhs.replace(1..4, "Al".bytes());
    concatenator.send_right(rhs.pull_changes()).for_each(|edit| concatenated.edit(edit));

    assert!(concatenated.to_string_lossy() == "Good day, Alfred");
}