Versions in this module Expand all Collapse all v0 v0.0.1 Nov 2, 2020 Changes in this version + type Chunk struct + Handler func(interface{}) interface{} + func NewChunk(size int) *Chunk + func (chunk *Chunk) Initialize() + type Options struct + BufferSize int + ChunkCount int + ChunkSize int + Handler func(interface{}) interface{} + func NewOptions() *Options + type ParallelChunkedFlow struct + func NewParallelChunkedFlow(options *Options) *ParallelChunkedFlow + func (pcf *ParallelChunkedFlow) Output() chan interface{} + func (pcf *ParallelChunkedFlow) Push(data interface{}) error