split

type Proc ¶

type Proc struct {
	// contains filtered or unexported fields
}

func (p *Proc) Done()

func (p *Proc) Pull() (zbuf.Batch, error)

type Splitter ¶

type Splitter struct {
	// contains filtered or unexported fields
}

Splitter splits its input into multiple proc outputs. Since procs run from the receiver backward via Pull(), SplitProc pulls data from upstream when all the outputs are ready, then sends the data downstream.

This scheme implements flow control since the SplitProc prevents any of the downstream from running ahead, esentially running the parallel paths at the rate of the slowest consumer.

func New(parent proc.Interface) *Splitter

func (s *Splitter) Add() chan (chan<- proc.Result)

func (s *Splitter) NewProc() *Proc