Stream Function
为了实时处理连续的高频数据， YoMo 采用 函数式响应式编程 (FRP)，让流计算变得前所未有的简单。 YoMo 使用 QUIC 传输协议， 很大程度上提高了数据传输的速度，并将 QUIC 流映射到 Rx 流。 用户可以使用 流操作符 (stream operators) 来处理他们想要处理的流:
func Handler(rxstream rx.Stream) rx.Stream {
stream := rxstream.
Debounce(50).
Map(computePeek).
SlidingWindowWithTime(SlidingWindowInMS, SlidingTimeInMS, slidingAvg)
return stream
}
除了将原始数据转换为可用信息之外，
流函数 (stream functions) 还可以在网页上实时展示数据，将流保存到时序数据库，或将排好格式的数据打印到StdOut:
func Handler(rxstream rx.Stream) rx.Stream {
stream := rxstream.
Map(store)
return stream
}
需要注意的几点:
zipper发送给stream function的数据流是 immutable 不可变的，stream function只能 append 新数据，不可修改原始 stream。
流操作符 (Stream Operators)
大多数 operators 将流作为 input 并返回一个新的流作为 output， 所以它们可以连接在一起。一些 operators 是由 ReactiveX 实现的:
Map - 对 Observable 发出的每个数据 apply 一个函数。
TakeLast - 获取 Observable 发出的最后 n 个数据。
一些 operators 是 YoMo 独有的:
AuditTimeDefaultIfEmptyWithTimeRawBytesSlidingWindowWithCountSlidingWindowWithTimeStdOutZipMultiObservers