# Functions
NewDeduplicate 保留不重复的.
NewDeduplicateWithKeys 保留不重复的,并传入已有的元素列表.
No description provided by the author
NewFilterAllRemain 保留所有.
NewFilterFirstN 保留前 n 个.
NewOperatorChain 处理链,将多个 Operator 串联起来,任一 Operator 失败直接中断.
NewOperatorSink 将 Operator 包装成 go-streams 支持的 Sink.
No description provided by the author
# Variables
No description provided by the author
# Structs
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Interfaces
Archiver 归档器,能够提供原有的数据的Keys,并且能够操作数据.
No description provided by the author
KeysInitiator 能够获取已有的数据的Keys.
Operator 能对 Cubox Item 进行处理.
Source 能够提供 Cubox Item 的数据源.
# Type aliases
No description provided by the author