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

v0

v0.3.0

Aug 23, 2026

Changes in this version

type Streamer

+ Ordered func() Streamer[T]

v0.2.0

Aug 23, 2026

Changes in this version

type Streamer

+ func DistinctBy[T any, K comparable](s Streamer[T], key func(T) K) Streamer[T]

+ func MapTo[T, R any](s Streamer[T], m types.Converter[T, R]) Streamer[R]

v0.1.0

Apr 20, 2026

Changes in this version

type Streamer

+ func From2[K, V any](seq iter.Seq2[K, V]) Streamer[V]

+ func From[T any](seq iter.Seq[T], sizeHint int64) Streamer[T]

+ FlatMap func(func(T) Streamer[any]) Streamer[any]

+ Seq func() iter.Seq[T]

v0.0.3

Nov 1, 2025

v0.0.2

Oct 10, 2023

Changes in this version

type Streamer

+ Any func() T

+ WithContext func(context.Context) Streamer[T]

v0.0.1

Oct 7, 2023

Changes in this version

+ var ErrUnsupportType = errors.New("unsupport type")

+ func AnyTo(data ...any) types.Collector[any]

+ func To(converter types.Converter[T, R]) types.Collector[T]

+ type Sortable struct

+ Cmp types.Comparator[T]

+ List []T

+ func (a *Sortable[T]) Len() int

+ func (a *Sortable[T]) Less(i, j int) bool

+ func (a *Sortable[T]) Swap(i, j int)

+ type Streamer interface

+ AllMatch func(types.Judge[T]) bool

+ AnyMatch func(types.Judge[T]) bool

+ Append func(...T) Streamer[T]

+ Collect func(types.Collector[T]) any

+ Convert func(types.Converter[T, any]) Streamer[any]

+ Count func() int64

+ Distinct func() Streamer[T]

+ Execute func() Streamer[T]

+ Filter func(types.Judge[T]) Streamer[T]

+ First func() T

+ ForEach func(types.Consumer[T])

+ Last func() T

+ Limit func(int64) Streamer[T]

+ Map func(types.Mapper[T]) Streamer[T]

+ NonMatch func(types.Judge[T]) bool

+ Parallel func(int) Streamer[T]

+ Peek func(types.Consumer[T]) Streamer[T]

+ Pick func(startIndex, endIndex, interval int) Streamer[T]

+ Reduce func(accumulator types.BinaryOperator[T]) T

+ ReduceBy func(initValueBulider func(sizeMayNegative int) any, ...) any

+ ReduceFrom func(initValue T, accumulator types.BinaryOperator[T]) T

+ ReduceWith func(initValue any, accumulator types.Accumulator[T, any]) any

+ Reverse func() Streamer[T]

+ ReverseSort func(types.Comparator[T]) Streamer[T]

+ Skip func(int64) Streamer[T]

+ Sort func(types.Comparator[T]) Streamer[T]

+ Take func() T

+ ToSlice func() []T

+ func Concat(dst Streamer[T], srcs ...Streamer[T]) Streamer[T]

+ func Of(supply types.Supplier[T]) Streamer[T]

+ func Repeat(t T) Streamer[T]

+ func RepeatN(t T, count int64) Streamer[T]

+ func SliceOf(slice ...T) Streamer[T]