creek

package module

Go to main page

Versions in this module

v1

v1.3.2

Jul 31, 2022

Changes in this version

type MapStream

+ func (s MapStream[T, V]) Keys() Stream[T]

+ func (s MapStream[T, V]) Values() Stream[V]

v1.3.1

Jul 20, 2022

Changes in this version

type MapStream

+ func (s MapStream[T, V]) Bind(v *map[T]V)

type Stream

+ func (s Stream[T]) Bind(v *[]T)

+ func (s Stream[T]) Skip(amount int) Stream[T]

type StructStream

+ func (s StructStream[T]) Bind(v *[]T)

+ func (s StructStream[T]) Skip(amount int) StructStream[T]

v1.3.0

Jul 19, 2022

Changes in this version

+ const ByKey

+ const ByValue

+ type KeyValuePair struct

+ Key T

+ Value V

+ type MapStream struct

+ Array []KeyValuePair[T, V]

+ func EmptyMap() MapStream[T, V]

+ func FromMap(m map[T]V) MapStream[T, V]

+ func (s MapStream[T, V]) All(expression func(KeyValuePair[T, V]) bool) bool

+ func (s MapStream[T, V]) Append(item KeyValuePair[T, V]) MapStream[T, V]

+ func (s MapStream[T, V]) AppendIf(item KeyValuePair[T, V], c bool) MapStream[T, V]

+ func (s MapStream[T, V]) Average(byKey bool) float64

+ func (s MapStream[T, V]) Clear() Stream[T]

+ func (s MapStream[T, V]) Collect() map[T]V

+ func (s MapStream[T, V]) ContainsKey(key T) bool

+ func (s MapStream[T, V]) Count() int

+ func (s MapStream[T, V]) ElementAt(index int) KeyValuePair[T, V]

+ func (s MapStream[T, V]) ElementAtOrElse(index int, elseValue KeyValuePair[T, V]) KeyValuePair[T, V]

+ func (s MapStream[T, V]) Filter(expression func(KeyValuePair[T, V]) bool) MapStream[T, V]

+ func (s MapStream[T, V]) Find(expression func(item KeyValuePair[T, V]) bool) KeyValuePair[T, V]

+ func (s MapStream[T, V]) FindIndex(expression func(item KeyValuePair[T, V]) bool) int

+ func (s MapStream[T, V]) FindLast(expression func(item KeyValuePair[T, V]) bool) KeyValuePair[T, V]

+ func (s MapStream[T, V]) FindLastIndex(expression func(item KeyValuePair[T, V]) bool) int

+ func (s MapStream[T, V]) First() KeyValuePair[T, V]

+ func (s MapStream[T, V]) ForEach(expression func(KeyValuePair[T, V]))

+ func (s MapStream[T, V]) IsEmpty() bool

+ func (s MapStream[T, V]) IsNotEmpty() bool

+ func (s MapStream[T, V]) Last() KeyValuePair[T, V]

+ func (s MapStream[T, V]) Map(expression func(item KeyValuePair[T, V]) KeyValuePair[T, V]) MapStream[T, V]

+ func (s MapStream[T, V]) Max(byKey bool) KeyValuePair[T, V]

+ func (s MapStream[T, V]) MaxIndex(byKey bool) int

+ func (s MapStream[T, V]) Min(byKey bool) KeyValuePair[T, V]

+ func (s MapStream[T, V]) MinIndex(byKey bool) int

+ func (s MapStream[T, V]) OrderBy(byKey bool) MapStream[T, V]

+ func (s MapStream[T, V]) OrderByDescending(byKey bool) MapStream[T, V]

+ func (s MapStream[T, V]) RemoveKey(key T) MapStream[T, V]

+ func (s MapStream[T, V]) RemoveValue(value V) MapStream[T, V]

+ func (s MapStream[T, V]) RemoveWhere(expression func(KeyValuePair[T, V]) bool) MapStream[T, V]

+ func (s MapStream[T, V]) Shuffle() MapStream[T, V]

+ func (s MapStream[T, V]) Some(expression func(item KeyValuePair[T, V]) bool) bool

+ func (s MapStream[T, V]) Sum(byKey bool) interface{}

+ func (s MapStream[T, V]) Wait(duration time.Duration) MapStream[T, V]

v1.2.3

Jul 13, 2022

Changes in this version

type Stream

+ func (s Stream[T]) BinarySearch(item T) int

+ func (s Stream[T]) Push(arr []T) Stream[T]

+ func (s Stream[T]) PushValues(values ...T) Stream[T]

type StructStream

+ func (s StructStream[T]) Push(arr []T) StructStream[T]

+ func (s StructStream[T]) PushValues(values ...T) StructStream[T]

v1.2.2

Jul 12, 2022

Changes in this version

type Stream

+ func (s Stream[T]) Replace(from T, to T) Stream[T]

+ func (s Stream[T]) ReplaceWhere(function func(item T) bool, to T) Stream[T]

+ func (s Stream[T]) Slice(start int, end int) Stream[T]

type StructStream

+ func (s StructStream[T]) Replace(from T, to T) StructStream[T]

+ func (s StructStream[T]) ReplaceWhere(function func(item T) bool, to T) StructStream[T]

+ func (s StructStream[T]) Slice(start int, end int) StructStream[T]

v1.2.1

Jul 11, 2022

Changes in this version

type Stream

+ func (s Stream[T]) First() T

+ func (s Stream[T]) IsNotEmpty() bool

+ func (s Stream[T]) Last() T

+ func (s Stream[T]) Shuffle() Stream[T]

type StructStream

+ func (s StructStream[T]) First() T

+ func (s StructStream[T]) IsNotEmpty() bool

+ func (s StructStream[T]) Last() T

+ func (s StructStream[T]) Shuffle() StructStream[T]

v1.2.0

Jul 10, 2022

Changes in this version

type Stream

+ func FromFile(file *os.File) Stream[string]

+ type StructStream struct

+ Array []T

+ func FromStructs(array []T) StructStream[T]

+ func (s StructStream[T]) All(expression func(item T) bool) bool

+ func (s StructStream[T]) Append(item T) StructStream[T]

+ func (s StructStream[T]) AppendAt(index int, item T) StructStream[T]

+ func (s StructStream[T]) AppendIf(item T, c bool) StructStream[T]

+ func (s StructStream[T]) ArrEquals(arr []T) bool

+ func (s StructStream[T]) Average(fieldName string) float64

+ func (s StructStream[T]) Clear() StructStream[T]

+ func (s StructStream[T]) Collect() []T

+ func (s StructStream[T]) Contains(item T) bool

+ func (s StructStream[T]) Count() int

+ func (s StructStream[T]) ElementAt(index int) T

+ func (s StructStream[T]) ElementAtOrElse(index int, elseValue T) T

+ func (s StructStream[T]) Equals(b StructStream[T]) bool

+ func (s StructStream[T]) Filter(expression func(item T) bool) StructStream[T]

+ func (s StructStream[T]) Find(expression func(item T) bool) T

+ func (s StructStream[T]) FindIndex(expression func(item T) bool) int

+ func (s StructStream[T]) FindLast(expression func(item T) bool) T

+ func (s StructStream[T]) FindLastIndex(expression func(item T) bool) int

+ func (s StructStream[T]) ForEach(expression func(item T))

+ func (s StructStream[T]) IndexOf(item T) int

+ func (s StructStream[T]) IsEmpty() bool

+ func (s StructStream[T]) LastIndexOf(item T) int

+ func (s StructStream[T]) Limit(amount int) StructStream[T]

+ func (s StructStream[T]) Map(expression func(item T) T) StructStream[T]

+ func (s StructStream[T]) Max(fieldName string) T

+ func (s StructStream[T]) MaxIndex(fieldName string) int

+ func (s StructStream[T]) Min(fieldName string) T

+ func (s StructStream[T]) MinIndex(fieldName string) int

+ func (s StructStream[T]) OrderBy(fieldName string) StructStream[T]

+ func (s StructStream[T]) OrderByDescending(fieldName string) StructStream[T]

+ func (s StructStream[T]) Remove(item T) StructStream[T]

+ func (s StructStream[T]) RemoveAt(index int) StructStream[T]

+ func (s StructStream[T]) RemoveIf(item T, c bool) StructStream[T]

+ func (s StructStream[T]) RemoveWhere(expression func(item T) bool) StructStream[T]

+ func (s StructStream[T]) Reverse() StructStream[T]

+ func (s StructStream[T]) Some(expression func(item T) bool) bool

+ func (s StructStream[T]) Sum(fieldName string) float64

+ func (s StructStream[T]) Wait(duration time.Duration) StructStream[T]

v1.1.0

Jul 9, 2022

Changes in this version

type Stream

+ func Empty() Stream[T]

+ func FromValues(values ...T) Stream[T]

+ func (s Stream[T]) All(expression func(item T) bool) bool

+ func (s Stream[T]) AppendIf(item T, c bool) Stream[T]

+ func (s Stream[T]) ArrEquals(arr []T) bool

+ func (s Stream[T]) Average() float64

+ func (s Stream[T]) Distinct() Stream[T]

+ func (s Stream[T]) ElementAt(index int) T

+ func (s Stream[T]) ElementAtOrElse(index int, elseValue T) T

+ func (s Stream[T]) Equals(b Stream[T]) bool

+ func (s Stream[T]) Find(expression func(item T) bool) T

+ func (s Stream[T]) FindIndex(expression func(item T) bool) int

+ func (s Stream[T]) FindLast(expression func(item T) bool) T

+ func (s Stream[T]) FindLastIndex(expression func(item T) bool) int

+ func (s Stream[T]) IndexOf(item T) int

+ func (s Stream[T]) LastIndexOf(item T) int

+ func (s Stream[T]) Max() T

+ func (s Stream[T]) MaxIndex() int

+ func (s Stream[T]) Min() T

+ func (s Stream[T]) MinIndex() int

+ func (s Stream[T]) RemoveIf(item T, c bool) Stream[T]

+ func (s Stream[T]) Some(expression func(item T) bool) bool

+ func (s Stream[T]) Sum() T

+ func (s Stream[T]) Wait(duration time.Duration) Stream[T]

v1.0.0

Jul 8, 2022

Changes in this version

+ type Stream struct

+ Array []T

+ func FromArray(array []T) Stream[T]

+ func (s Stream[T]) Append(item T) Stream[T]

+ func (s Stream[T]) AppendAt(index int, item T) Stream[T]

+ func (s Stream[T]) Clear() Stream[T]

+ func (s Stream[T]) Collect() []T

+ func (s Stream[T]) Contains(item T) bool

+ func (s Stream[T]) Count() int

+ func (s Stream[T]) Filter(expression func(item T) bool) Stream[T]

+ func (s Stream[T]) ForEach(expression func(item T))

+ func (s Stream[T]) IsEmpty() bool

+ func (s Stream[T]) Join(separator string) string

+ func (s Stream[T]) Limit(amount int) Stream[T]

+ func (s Stream[T]) Map(expression func(item T) T) Stream[T]

+ func (s Stream[T]) OrderBy() Stream[T]

+ func (s Stream[T]) OrderByDescending() Stream[T]

+ func (s Stream[T]) Remove(item T) Stream[T]

+ func (s Stream[T]) RemoveAt(index int) Stream[T]

+ func (s Stream[T]) RemoveDuplicates() Stream[T]

+ func (s Stream[T]) RemoveWhere(expression func(item T) bool) Stream[T]

+ func (s Stream[T]) Reverse() Stream[T]

+ type Streamable interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL