StreamSkip.yqls 448 B

123456789101112
  1. (
  2. #comment
  3. (let config (DataSource 'config))
  4. (let res_sink (DataSink 'result))
  5. (let list1 (AsList (Uint32 '1) (Uint32 '2) (Uint32 '3)))
  6. (let list2 (AsList (Uint32 '4) (Uint32 '5) (Uint32 '6)))
  7. (let world (Write! world res_sink (Key) (Collect (Skip (Iterator list1) (Uint64 '2))) '('('type))))
  8. (let world (Write! world res_sink (Key) (Collect (Skip (Iterator list2) (Uint64 '0))) '('('type))))
  9. (let world (Commit! world res_sink))
  10. (return world)
  11. )