Aggregator

constructor(    zero: () -> BUF,     reduce: (b: BUF, a: IN) -> BUF,     merge: (b1: BUF, b2: BUF) -> BUF,     finish: (reduction: BUF) -> OUT,     bufferEncoder: Encoder<BUF>,     outputEncoder: Encoder<OUT>)