Documentation ¶
Index ¶
- Constants
- type Parallel
- type Sink
- type 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
Constants ¶
View Source
const STOP = math.MaxUint64
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Source ¶
type Source func() Stream
func (Source) LuckyCollect ¶
func (zf Source) LuckyCollect() interface{}
func (Source) LuckyCount ¶
Click to show internal directories.
Click to hide internal directories.