lazy

Documentation

Index

• Constants
• type Parallel
• type Sink
• type Source
  • func Chan(c interface{}, stop ...chan struct{}) Source
  • func Flatn(listarr interface{}) Source
  • func List(list interface{}) Source
  • func (zf Source) Chain(zx Source, eqt ...func(a, b reflect.Value) bool) Source
  • func (zf Source) Collect() (r interface{}, err error)
  • func (zf Source) Count() (count int, err error)
  • func (zf Source) Drain(sink func(reflect.Value) error) (err error)
  • func (zf Source) Filter(f interface{}) Source
  • func (zf Source) First(n int) Source
  • func (zf Source) LuckyCollect() interface{}
  • func (zf Source) LuckyCount() int
  • func (zf Source) Map(f interface{}) Source
  • func (zf Source) Parallel(concurrency ...int) Source
  • func (zf Source) Rand(seed int, prob float64) Source
  • func (zf Source) RandFilter(seed int, prob float64, t bool) Source
  • func (zf Source) RandSkip(seed int, prob float64) Source
• type Stream
  • func Error(err error, z ...Stream) Stream
  • func Wrap(e interface{}) Stream

Constants

const STOP = math.MaxUint64

Types

type Parallel

type Parallel int

type Sink

type Sink func(reflect.Value) error

type Source

type Source func() Stream

func Chan

func Chan(c interface{}, stop ...chan struct{}) Source

func Flatn

func Flatn(listarr interface{}) Source

func List

func List(list interface{}) Source

func (Source) Chain

func (zf Source) Chain(zx Source, eqt ...func(a, b reflect.Value) bool) Source

func (Source) Collect

func (zf Source) Collect() (r interface{}, err error)

func (Source) Count

func (zf Source) Count() (count int, err error)

func (Source) Drain

func (zf Source) Drain(sink func(reflect.Value) error) (err error)

func (Source) Filter

func (zf Source) Filter(f interface{}) Source

func (Source) First

func (zf Source) First(n int) Source

func (Source) LuckyCollect

func (zf Source) LuckyCollect() interface{}

func (Source) LuckyCount

func (zf Source) LuckyCount() int

func (Source) Map

func (zf Source) Map(f interface{}) Source

func (Source) Parallel

func (zf Source) Parallel(concurrency ...int) Source

func (Source) Rand

func (zf Source) Rand(seed int, prob float64) Source

func (Source) RandFilter

func (zf Source) RandFilter(seed int, prob float64, t bool) Source

func (Source) RandSkip

func (zf Source) RandSkip(seed int, prob float64) Source

type Stream

type Stream func(index uint64) (reflect.Value, error)

func Error

func Error(err error, z ...Stream) Stream

func Wrap

func Wrap(e interface{}) Stream