Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stream

package module

Go to main page

Versions in this module

v1

v1.1.1

Sep 5, 2022

Changes in this version

+ type Pair interface

+ First func() T1

+ Second func() T2

+ Value func() (T1, T2)

+ func NewPair(first T1, second T2) Pair[T1, T2]

+ type Quadruple interface

+ First func() T1

+ Forth func() T4

+ Second func() T2

+ Third func() T3

+ Value func() (T1, T2, T3, T4)

+ func NewQuadruple(first T1, second T2, third T3, forth T4) Quadruple[T1, T2, T3, T4]

+ type Quintuple interface

+ Fifth func() T5

+ First func() T1

+ Forth func() T4

+ Second func() T2

+ Third func() T3

+ Value func() (T1, T2, T3, T4, T5)

+ func NewQuintuple(first T1, second T2, third T3, forth T4, fifth T5) Quintuple[T1, T2, T3, T4, T5]

type Stream

+ func Flatten(v Stream[T1], expander func(i T1) []T2) Stream[T2]

+ func Pack2(v Stream[T]) Stream[Pair[T, T]]

+ func Pack3(v Stream[T]) Stream[Triple[T, T, T]]

+ func Pack4(v Stream[T]) Stream[Quadruple[T, T, T, T]]

+ func Pack5(v Stream[T]) Stream[Quintuple[T, T, T, T, T]]

+ func WrapStream(src Stream[T1], iter Iterator[T2]) Stream[T2]

+ type Triple interface

+ First func() T1

+ Second func() T2

+ Third func() T3

+ Value func() (T1, T2, T3)

+ func NewTriple(first T1, second T2, third T3) Triple[T1, T2, T3]

v1.1.0

Feb 18, 2022

Changes in this version

+ type Comparator func(arg1, arg2 T) int

+ type Number interface

type Optional

+ func Sum(v Stream[T]) Optional[T]

type Stream

+ func Map(src Stream[F], f func(in F) T) Stream[T]

+ EachCondition func(func(T) bool)

v1.0.0

Feb 11, 2022

Changes in this version

+ var SumFloat32 = func(i, j interface{}) interface{}

+ var SumFloat64 = func(i, j interface{}) interface{}

+ var SumInt = func(i, j interface{}) interface{}

+ var SumInt32 = func(i, j interface{}) interface{}

+ var SumInt64 = func(i, j interface{}) interface{}

+ var SumUint32 = func(i, j interface{}) interface{}

+ var SumUint64 = func(i, j interface{}) interface{}

+ func CollectAll(iter Iterator) []interface

+ func CollectN(iter Iterator, count int) []interface

+ type ChannelIterator struct

+ func NewChannelIterator(target interface{}) *ChannelIterator

+ func (v *ChannelIterator) Next() (result interface{}, ok bool)

+ type GenFunc func() interface

+ type Iterator interface

+ Next func() (val interface{}, ok bool)

+ func NewArrayIterator(target interface{}) Iterator

+ type LessThanCmpFunc func(x, y interface{}) bool

+ var NaturalCmpFunc LessThanCmpFunc = func(i, j interface{}) bool { ... }

+ type MapCallFunc func(x interface{})

+ type MapEntry struct

+ Key interface{}

+ Value interface{}

+ type MapEntryIterator struct

+ func NewMapEntryIterator(target interface{}) *MapEntryIterator

+ func (v *MapEntryIterator) Next() (result interface{}, ok bool)

+ type MapFunc func(x interface{}) interface

+ type MapKeyIterator struct

+ func NewMapKeyIterator(target interface{}) *MapKeyIterator

+ func (v *MapKeyIterator) Next() (result interface{}, ok bool)

+ type MapValueIterator struct

+ func NewMapValueIterator(target interface{}) *MapValueIterator

+ func (v *MapValueIterator) Next() (result interface{}, ok bool)

+ type NumberedItem struct

+ Index int

+ Item interface{}

+ type Optional interface

+ Or func(other Optional) Optional

+ OrValue func(defaultV interface{}) interface{}

+ Value func() (interface{}, bool)

+ func NewEmptyOptional() Optional

+ func NewOptional(val interface{}) Optional

+ type PredictFunc func(x interface{}) bool

+ type ProducerFunc func() interface

+ type ReduceFunc func(x, y interface{}) interface

+ type Stream interface

+ Close func()

+ CollectTo func(target interface{}) int

+ Concat func(other Stream) Stream

+ Count func() int

+ Each func(f interface{})

+ Filter func(f interface{}) Stream

+ Iterator func() Iterator

+ Limit func(number int) Stream

+ Map func(f interface{}) Stream

+ Max func() Optional

+ MaxCmp func(f interface{}) Optional

+ Min func() Optional

+ MinCmp func(f interface{}) Optional

+ OnClose func(closefunc func()) Stream

+ Peek func(f interface{}) Stream

+ Reduce func(f interface{}) Optional

+ SendTo func(channel interface{})

+ Skip func(number int) Stream

+ Sum func() Optional

+ func FromArray(it interface{}) Stream

+ func FromChannel(it interface{}) Stream

+ func FromFileLines(filepath string) (Stream, error)

+ func FromIterator(it Iterator) Stream

+ func FromMapEntries(it interface{}) Stream

+ func FromMapKeys(it interface{}) Stream

+ func FromMapValues(it interface{}) Stream

+ func FromReader(r io.Reader, delimeter rune) Stream

+ func Generate(f interface{}) Stream

+ func Iterate(seed interface{}, f interface{}) Stream

+ func Of(vars ...interface{}) Stream

+ func Range(low, high int) Stream

+ func WithIndex(in Stream) Stream

+ type ValueFunc func() []interface

+ type VoidFunc func()