blob: 78557d82b83df0592529bf3c69f313514dfdd974 (
plain) (
blame)
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
|
(
#comment
(let config (DataSource 'config))
(let world (Configure! world config 'PureDataSource 'yt))
(let res_sink (DataSink 'result))
(let list (AsList
'((Uint32 '1) (String 'b))
'((Uint32 '2) (String 'o))
'((Uint32 '1) (String 'm))
'((Uint32 '3) (String 'b))))
(let init_state '((Uint32 '0) (String '"")))
(let update (lambda '(item state) (block '(
(let key (Nth item '0))
(let val (Nth item '1))
(let skey (Nth state '0))
(let sval (Nth state '1))
(let skey (+ skey key))
(let sval (Concat sval val))
(let new_item '(key val skey sval))
(let new_state '(skey sval))
(return '(new_item new_state)
)))))
(let result (FoldMap (Iterator list) init_state update))
(let world (Write! world res_sink (Key) (Collect result) '('('type))))
(let world (Commit! world res_sink))
(return world)
)
|
