Versions in this module Expand all Collapse all v1 v1.0.0 May 12, 2021 Changes in this version + func Count() collector + func CountV2() collectorV2 + func GroupBy(typ interface{}, classifier normalizedFn, downstream collector) collector + func GroupByV2(typ interface{}, classifier normalizedFn, downstream collectorV2) collectorV2 + func ToMap(typ interface{}, keyMapper, valueMapper normalizedFn) collector + func ToMapV2(typ interface{}, keyMapper, valueMapper normalizedFn) collectorV2 + func ToSlice(typ interface{}) collector + func ToSliceBy(typ interface{}, mapper normalizedFn) collector + func ToSliceByV2(typ interface{}, mapper normalizedFn) collectorV2 + func ToSliceV2(typ interface{}) collectorV2 + type KeyValue = linq.KeyValue + type Stream linq.Query + func From(source interface{}) Stream + func Zip2By(left, right Stream, fn zip2Fn) Stream + func Zip3By(first, second, third Stream, fn zip3Fn) Stream + func (s Stream) All(predicate func(interface{}) bool) bool + func (s Stream) Any() bool + func (s Stream) AnyWith(predicate func(interface{}) bool) bool + func (s Stream) Collect(c collector) interface{} + func (s Stream) CollectV2(c collectorV2) interface{} + func (s Stream) Contains(value interface{}) bool + func (s Stream) Count() int + func (s Stream) Drop(n int) Stream + func (s Stream) Filter(predicate func(interface{}) bool) Stream + func (s Stream) First() (interface{}, bool) + func (s Stream) FlatMap(mapper func(interface{}) Stream) Stream + func (s Stream) ForEach(action func(interface{})) + func (s Stream) ForEachIndexed(action func(int, interface{})) + func (s Stream) Last() (interface{}, bool) + func (s Stream) Limit(n int) Stream + func (s Stream) Linq() linq.Query + func (s Stream) Map(mapper normalizedFn) Stream + func (s Stream) OutMap(out interface{}) + func (s Stream) OutSlice(out interface{}) + func (s Stream) Partition(typ interface{}, size int) Stream + func (s Stream) Peek(fn func(interface{})) Stream + func (s Stream) Process(fn func(interface{}) error) error + func (s Stream) Reduce(accumulator accumulatorFn) interface{} + func (s Stream) ReduceWith(seed interface{}, accumulator accumulatorFn) interface{} + func (s Stream) SortedBy(fn normalizedFn) Stream + func (s Stream) SortedDescBy(fn normalizedFn) Stream + func (s Stream) ToMap(typ interface{}) interface{} + func (s Stream) ToSlice(typ interface{}) interface{}