seq_util

Documentation

Index

• func Batch[T any](seq iter.Seq[T], batchSize int) iter.Seq[[]T]
• func Buffer[T any](seq iter.Seq[T], size int) iter.Seq[T]
• func Buffer2[F1, F2 any](seq iter.Seq2[F1, F2], size int) iter.Seq2[F1, F2]
• func Concat[T any](seqs ...iter.Seq[T]) iter.Seq[T]
• func Concat2[K, V any](seqs ...iter.Seq2[K, V]) iter.Seq2[K, V]
• func Count[T any](seq iter.Seq[T]) int
• func Count2[T1 any, T2 any](seq iter.Seq2[T1, T2]) int
• func Drain[T any](seq iter.Seq[T], fn func(T) bool) iter.Seq[T]
• func Filter[T any](seq iter.Seq[T], fn func(T) bool) iter.Seq[T]
• func Filter2[T1 any, T2 any](seq iter.Seq2[T1, T2], fn func(T1, T2) bool) iter.Seq2[T1, T2]
• func Flat[F any](seq iter.Seq[iter.Seq[F]]) iter.Seq[F]
• func Flat12[F1 any, F2 any](seq iter.Seq[iter.Seq2[F1, F2]]) iter.Seq2[F1, F2]
• func FlatInnerResultSlice[F any](s iter.Seq2[[]F, error]) iter.Seq2[F, error]
• func FlatInnerSlice[F any](s iter.Seq[[]F]) iter.Seq[F]
• func FlatOuterSlice[F any](s []iter.Seq[F]) iter.Seq[F]
• func FromPairSlice[K, V any](slice []Pair[K, V]) iter.Seq2[K, V]
• func FromSlice[T any](slice []T) iter.Seq[T]
• func FromSlice2[F1, F2 any](slice []Pair[F1, F2]) iter.Seq2[F1, F2]
• func Log[T any](seq iter.Seq[T], fn func(int64, T), sampleRate int64) iter.Seq[T]
• func Log2[T1 any, T2 any](seq iter.Seq2[T1, T2], fn func(int64, T1, T2), sampleRate int64) iter.Seq2[T1, T2]
• func Map[F any, T any](seq iter.Seq[F], fn func(F) T) iter.Seq[T]
• func Map12[F, T1, T2 any](seq iter.Seq[F], fn func(F) (T1, T2)) iter.Seq2[T1, T2]
• func Map21[F1 any, F2 any, T any](seq iter.Seq2[F1, F2], fn func(F1, F2) T) iter.Seq[T]
• func MapResult[T any, R any](seq iter.Seq[T], fn func(T) (R, error)) iter.Seq2[R, error]
• func MapResult2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(T1, T2) (R, error)) iter.Seq2[R, error]
• func Reduce[T any, R any](seq iter.Seq[T], fn func(R, T) R, init R) R
• func Reduce2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(R, T1, T2) R, init R) R
• func ReduceUntil[T any, R any](seq iter.Seq[T], fn func(R, T) (R, bool), init R) R
• func ReduceUntil2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(R, T1, T2) (R, bool), init R) R
• func Skip[T any](seq iter.Seq[T], n int) iter.Seq[T]
• func Skip2[T1 any, T2 any](seq iter.Seq2[T1, T2], n int) iter.Seq2[T1, T2]
• func UnwrapOrStop[T any](seq iter.Seq2[T, error], stopError *error, stopData *T, ...) iter.Seq[T]
• type Pair
• type Result

Functions

func Batch

func Batch[T any](seq iter.Seq[T], batchSize int) iter.Seq[[]T]

func Buffer

func Buffer[T any](seq iter.Seq[T], size int) iter.Seq[T]

func Buffer2

func Buffer2[F1, F2 any](seq iter.Seq2[F1, F2], size int) iter.Seq2[F1, F2]

func Concat

func Concat[T any](seqs ...iter.Seq[T]) iter.Seq[T]

func Concat2

func Concat2[K, V any](seqs ...iter.Seq2[K, V]) iter.Seq2[K, V]

func Count

func Count[T any](seq iter.Seq[T]) int

func Count2

func Count2[T1 any, T2 any](seq iter.Seq2[T1, T2]) int

func Drain

func Drain[T any](seq iter.Seq[T], fn func(T) bool) iter.Seq[T]

func Filter

func Filter[T any](seq iter.Seq[T], fn func(T) bool) iter.Seq[T]

func Filter2

func Filter2[T1 any, T2 any](seq iter.Seq2[T1, T2], fn func(T1, T2) bool) iter.Seq2[T1, T2]

func Flat

func Flat[F any](seq iter.Seq[iter.Seq[F]]) iter.Seq[F]

func Flat12

func Flat12[F1 any, F2 any](seq iter.Seq[iter.Seq2[F1, F2]]) iter.Seq2[F1, F2]

func FlatInnerResultSlice

func FlatInnerResultSlice[F any](s iter.Seq2[[]F, error]) iter.Seq2[F, error]

func FlatInnerSlice

func FlatInnerSlice[F any](s iter.Seq[[]F]) iter.Seq[F]

func FlatOuterSlice

func FlatOuterSlice[F any](s []iter.Seq[F]) iter.Seq[F]

func FromPairSlice

func FromPairSlice[K, V any](slice []Pair[K, V]) iter.Seq2[K, V]

func FromSlice

func FromSlice[T any](slice []T) iter.Seq[T]

func FromSlice2

func FromSlice2[F1, F2 any](slice []Pair[F1, F2]) iter.Seq2[F1, F2]

func Log

func Log[T any](seq iter.Seq[T], fn func(int64, T), sampleRate int64) iter.Seq[T]

func Log2

func Log2[T1 any, T2 any](seq iter.Seq2[T1, T2], fn func(int64, T1, T2), sampleRate int64) iter.Seq2[T1, T2]

func Map

func Map[F any, T any](seq iter.Seq[F], fn func(F) T) iter.Seq[T]

func Map12

func Map12[F, T1, T2 any](seq iter.Seq[F], fn func(F) (T1, T2)) iter.Seq2[T1, T2]

func Map21

func Map21[F1 any, F2 any, T any](seq iter.Seq2[F1, F2], fn func(F1, F2) T) iter.Seq[T]

func MapResult

func MapResult[T any, R any](seq iter.Seq[T], fn func(T) (R, error)) iter.Seq2[R, error]

func MapResult2

func MapResult2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(T1, T2) (R, error)) iter.Seq2[R, error]

func Reduce

func Reduce[T any, R any](seq iter.Seq[T], fn func(R, T) R, init R) R

func Reduce2

func Reduce2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(R, T1, T2) R, init R) R

func ReduceUntil

func ReduceUntil[T any, R any](seq iter.Seq[T], fn func(R, T) (R, bool), init R) R

func ReduceUntil2

func ReduceUntil2[T1 any, T2 any, R any](seq iter.Seq2[T1, T2], fn func(R, T1, T2) (R, bool), init R) R

func Skip

func Skip[T any](seq iter.Seq[T], n int) iter.Seq[T]

func Skip2

func Skip2[T1 any, T2 any](seq iter.Seq2[T1, T2], n int) iter.Seq2[T1, T2]

func UnwrapOrStop

func UnwrapOrStop[T any](seq iter.Seq2[T, error], stopError *error, stopData *T, cb func(error, T) error) iter.Seq[T]

Types

type Pair

type Pair[K any, V any] struct {
	K K
	V V
}

type Result

type Result[T any] struct {
	Data T
	Err  error
}