seq_util

package

v0.0.0-...-2b21926 Latest Latest Go to latest Published: Jan 10, 2026 License: LGPL-3.0 Imports: 1 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/fancy-go/utils

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

seq_util.go

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