GroupByKeyFunc generates an api.UnFunc that groups incoming batched items by key value.

GroupByNameFunc generates an api.UnFunc that groups incoming batched items by struct field name.

GroupByPosFunc generates an api.Unary function that groups incoming batched items by their position in a slice.

New returns a new BatchOperator operator delayLast: latest value included in next batch instead of current batch.

SortByKeyFunc generates a api.UnFunc operation that sorts batched items from upsteram using the key value of maps in the batch.

SortByNameFunc generates a api.UnFunc operation that sorts batched items from upstream using the field name of items in the batch.

SortByPosFunc generates a api.UnFunc that sorts batched data from upstream.

SortFunc generates an api.UnFunc that sorts batched data from upstream.

SortWithFunc generates an api.UnFunc operation that is intended to sort batched items from upstream using the provided Less function to be used with the sort package.

SumByKeyFunc generates an api.UnFunc that sums incoming batched items by key value.

SumByNameFunc generates an api.UnFunc that sums incoming batched items by sturct field name.

SumByPosFunc generates an api.UnFunc that sums incoming values from upstream batched items based on their position.

Sum generates an api.UnFunc that sums batched items from upstream.

TriggerAll forces the batch trigger to always return false meaning it's never done, causing the batch to exhaust all stream items.

TriggerBySize triggers batch based on the specified size.

BatchOperator is an executor that batches incoming streamed items based on provided criteria.