Versions in this module Expand all Collapse all v1 v1.0.1 Feb 16, 2017 v1.0.0 Jan 5, 2017 Changes in this version + func Lazily(f Evaluator, lookahead int, reaper <-chan struct{}, init ...interface{}) func() interface + func Map(set Mapper, threads, maxChunkSize int) (results []interface{}, err error) + type Concurrent interface + Process func(...interface{}) + Result func() (interface{}, error) + type Evaluator func(...interface{}) (interface{}, State) + type Mapper interface + Len func() int + Slice func(i, j int) Mapper + type Operator interface + Operation func() (interface{}, error) + type Processor struct + func NewProcessor(queue chan Operator, buffer int, threads int) (p *Processor) + func (p *Processor) Close() + func (p *Processor) Process(value ...Operator) + func (p *Processor) Result() (interface{}, error) + func (p *Processor) Stop() + func (p *Processor) Wait() + func (p *Processor) Working() int + type Promise struct + func NewPromise(mutable, recoverable, relay bool) *Promise + func PromiseMap(set Mapper, threads, maxChunkSize int) *Promise + func (p *Promise) Break() + func (p *Promise) Fail(value interface{}, err error) (ok bool) + func (p *Promise) Fulfill(value interface{}) error + func (p *Promise) Recover(value interface{}) (ok bool) + func (p *Promise) Wait() <-chan Result + type Result struct + Err error + Value interface{} + type State []interface
Go to main page