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
use std::sync::Arc;
use loro_internal::{
cursor::PosType,
event::Diff,
handler::{Handler, ValueOrHandler},
ListHandler, LoroDoc, MapHandler, TextHandler, ToJson, TreeHandler,
};
fn main() {
let doc = LoroDoc::new();
doc.start_auto_commit();
let list = doc.get_list("list");
let _g = doc.subscribe_root(Arc::new(|e| {
for container_diff in e.events {
match &container_diff.diff {
Diff::List(list) => {
for item in list.iter() {
if let loro_delta::DeltaItem::Replace { value, .. } = item {
for v in value.iter() {
match v {
ValueOrHandler::Handler(h) => {
// You can directly obtain the handler and perform some operations.
if matches!(h, Handler::Map(_)) {
let text = h
.as_map()
.unwrap()
.insert_container(
"text",
TextHandler::new_detached(),
)
.unwrap();
text.insert(0, "created from event", PosType::Unicode)
.unwrap();
}
}
ValueOrHandler::Value(value) => {
println!("insert value {value:?}");
}
}
}
}
}
}
Diff::Map(map) => {
println!("map container updates {:?}", map.updated);
}
_ => {}
}
}
}));
list.insert(0, "abc").unwrap();
list.insert_container(1, ListHandler::new_detached())
.unwrap();
list.insert_container(2, MapHandler::new_detached())
.unwrap();
list.insert_container(3, TextHandler::new_detached())
.unwrap();
list.insert_container(4, TreeHandler::new_detached())
.unwrap();
doc.commit_then_renew();
assert_eq!(
doc.get_deep_value().to_json(),
r#"{"list":["abc",[],{"text":"created from event"},"",[]]}"#
);
}