Versions in this module Expand all Collapse all v10 v10.0.0 Nov 11, 2020 Changes in this version + const PanicDuplicateKey + const PanicInvalidConcurrencyLevel + const PanicMissingChannel + const PanicNoSuchElement + func EntriesEqual(e1, e2 Entry) bool + func False(t Entry) bool + func True(t Entry) bool + type BiConsumer func(i, j Entry) + type BiFunction func(e1, e2 Entry) Entry + type CStream struct + func NewCStream(channels []chan Entry) CStream + func (cs CStream) AddStreamFromChannels(channels []chan Entry) CStream + func (cs CStream) AddStreamFromSlices(slices []EntrySlice, bufsize int) CStream + func (cs CStream) AddStreams(streams []Stream) CStream + func (cs CStream) Filter(predicate Predicate) CStream + func (cs CStream) ForEach(consumer Consumer) + type Collector struct + func Filtering(predicate Predicate, collector Collector) Collector + func FlatMapping(mapper StreamFunction, collector Collector) Collector + func GroupingBy(classifier Function, downstream Collector) Collector + func Mapping(mapper Function, collector Collector) Collector + func NewCollector(supplier Supplier, accumulator BiFunction, finisher Function) Collector + func Reducing(f2 BiFunction) Collector + func ToEntryMap(keyMapper, valueMapper Function) Collector + func ToEntryMapWithKeyMerge(keyMapper, valueMapper Function, mergeFunction BiFunction) Collector + func ToEntrySlice() Collector + type Consumer func(i Entry) + type Entry interface + Equal func(Entry) bool + Hash func() uint32 + func IdentityFinisher(e Entry) Entry + type EntryBool bool + func (eb EntryBool) Equal(e Entry) bool + func (eb EntryBool) Hash() uint32 + type EntryByte byte + func (i EntryByte) Equal(e Entry) bool + func (i EntryByte) Hash() uint32 + type EntryFloat float32 + func (f EntryFloat) Equal(e Entry) bool + func (f EntryFloat) Hash() uint32 + type EntryInt int + func (i EntryInt) Equal(e Entry) bool + func (i EntryInt) Hash() uint32 + type EntryMap map[Entry]Entry + func (em EntryMap) Equal(e Entry) bool + func (em EntryMap) HasKey(key Entry) bool + func (em EntryMap) Hash() uint32 + func (em EntryMap) Len() int + func (em EntryMap) Merge(key, value Entry, mergeFunction BiFunction) EntryMap + func (em EntryMap) Stream(bufsize int) Stream + type EntrySlice []Entry + func (es EntrySlice) Append(e Entry) EntrySlice + func (es EntrySlice) Equal(e Entry) bool + func (es EntrySlice) Hash() uint32 + func (es EntrySlice) Len() int + type EntryString string + func (es EntryString) Equal(e Entry) bool + func (es EntryString) Hash() uint32 + func (es EntryString) Len() EntryInt + func (es EntryString) MapToEntryBytes(bufsize int) Stream + func (es EntryString) ToLower() EntryString + func (es EntryString) ToUpper() EntryString + type FloatStream struct + func NewConcurrentFloatStream(c chan EntryFloat, n int) FloatStream + func NewFloatStream(c chan EntryFloat) FloatStream + func NewFloatStreamFromSlice(is []EntryFloat, bufsize int) FloatStream + func (is FloatStream) Average() EntryFloat + func (is FloatStream) Max() EntryFloat + func (is FloatStream) Min() EntryFloat + func (is FloatStream) Sum() EntryFloat + type Function func(e Entry) Entry + type IntStream struct + func NewConcurrentIntStream(c chan EntryInt, n int) IntStream + func NewIntStream(c chan EntryInt) IntStream + func NewIntStreamFromSlice(is []EntryInt, bufsize int) IntStream + func (is IntStream) Average() EntryInt + func (is IntStream) Max() EntryInt + func (is IntStream) Min() EntryInt + func (is IntStream) Sum() EntryInt + type Maybe struct + func MaybeNone() Maybe + func MaybeOf(i Entry) Maybe + func MaybeSome(i Entry) Maybe + func (m Maybe) Filter(predicate Predicate) Maybe + func (m Maybe) Get() Entry + func (m Maybe) GetOrElse(elseEntry Entry) Entry + func (m Maybe) IsEmpty() bool + func (m Maybe) OrElse(elseMaybe Maybe) Maybe + type Predicate func(t Entry) bool + func FunctionPredicate(f Function) Predicate + func (p Predicate) And(other Predicate) Predicate + func (p Predicate) Negate() Predicate + func (p Predicate) Not() Predicate + func (p Predicate) Or(other Predicate) Predicate + func (p Predicate) Xor(other Predicate) Predicate + type Stream struct + func NewConcurrentStream(c chan Entry, n int) Stream + func NewStream(c chan Entry) Stream + func NewStreamFromSlice(slice EntrySlice, bufsize int) Stream + func (s Stream) AllMatch(p Predicate) bool + func (s Stream) AnyMatch(p Predicate) bool + func (s Stream) Collect(c Collector) interface{} + func (s Stream) Concurrent(n int) Stream + func (s Stream) Count() int + func (s Stream) Distinct() Stream + func (s Stream) Drop(n uint64) Stream + func (s Stream) DropUntil(p Predicate) Stream + func (s Stream) DropWhile(p Predicate) Stream + func (s Stream) EndsWith(slice EntrySlice) bool + func (s Stream) Filter(predicate Predicate) Stream + func (s Stream) FlatMap(mapper StreamFunction) Stream + func (s Stream) ForEach(consumer Consumer) + func (s Stream) ForEachC(consumer Consumer) + func (s Stream) GroupBy(classifier Function) EntryMap + func (s Stream) Head() Entry + func (s Stream) HeadN(n uint64) EntrySlice + func (s Stream) Intersperse(e Entry) Stream + func (s Stream) Last() Entry + func (s Stream) LastN(n uint64) EntrySlice + func (s Stream) LeftReduce(f2 BiFunction) Entry + func (s Stream) Limit(n uint64) Stream + func (s Stream) Map(mapper Function) Stream + func (s Stream) MapToFloat(toFloat ToFloatFunction) FloatStream + func (s Stream) MapToInt(toInt ToIntFunction) IntStream + func (s Stream) NoneMatch(p Predicate) bool + func (s Stream) Peek(consumer Consumer) Stream + func (s Stream) Reduce(f2 BiFunction) Entry + func (s Stream) StartsWith(slice EntrySlice) bool + func (s Stream) Take(n uint64) Stream + func (s Stream) TakeUntil(p Predicate) Stream + func (s Stream) TakeWhile(p Predicate) Stream + func (s Stream) ToSlice() EntrySlice + type StreamFunction func(e Entry) Stream + func FlattenEntrySliceToEntry(bufsize int) StreamFunction + type Supplier func() Entry + type ToFloatFunction func(e Entry) EntryFloat + type ToIntFunction func(e Entry) EntryInt + type Tuple0 struct + func (t Tuple0) Arity() int + func (t Tuple0) Equal(o Entry) bool + func (t Tuple0) Hash() uint32 + func (t Tuple0) ToSlice() EntrySlice + type Tuple1 struct + E1 Entry + func (t Tuple1) Arity() int + func (t Tuple1) Equal(o Entry) bool + func (t Tuple1) Hash() uint32 + func (t Tuple1) Map(mapper Function) Tuple1 + func (t Tuple1) MapMulti(mapper1 Function) Tuple1 + func (t Tuple1) ToSlice() EntrySlice + type Tuple2 struct + E1 Entry + E2 Entry + func (t Tuple2) Arity() int + func (t Tuple2) Equal(o Entry) bool + func (t Tuple2) Hash() uint32 + func (t Tuple2) Map(mapper Function) Tuple2 + func (t Tuple2) MapMulti(mapper1 Function, mapper2 Function) Tuple2 + func (t Tuple2) ToSlice() EntrySlice + type Tuple3 struct + E1 Entry + E2 Entry + E3 Entry + func (t Tuple3) Arity() int + func (t Tuple3) Equal(o Entry) bool + func (t Tuple3) Hash() uint32 + func (t Tuple3) Map(mapper Function) Tuple3 + func (t Tuple3) MapMulti(mapper1 Function, mapper2 Function, mapper3 Function) Tuple3 + func (t Tuple3) ToSlice() EntrySlice Other modules containing this package github.com/seborama/fuego github.com/seborama/fuego/v11 github.com/seborama/fuego/v12 github.com/seborama/fuego/v9
Go to main page