chanx

Documentation

Index

• func Batch[T any](ctx context.Context, ch <-chan T, batchSize int, fn func([]T))
• func BatchFilter[T, V any](ctx context.Context, ch <-chan T, batchSize int, filter func(T) V, ...)
• func FlatBatch[T any](ctx context.Context, ch <-chan []T, batchSize int, fn func([]T))
• func FlatBatchFilter[T, V any](ctx context.Context, ch <-chan []T, batchSize int, filter func(T) V, ...)

Functions

func Batch

func Batch[T any](ctx context.Context, ch <-chan T, batchSize int, fn func([]T))

Batch reads from a channel and calls fn with a slice of batchSize.

func BatchFilter

func BatchFilter[T, V any](ctx context.Context, ch <-chan T, batchSize int, filter func(T) V, fn func([]V))

BatchFilter reads from a channel, filters values, and calls fn with a slice of batchSize.

func FlatBatch

func FlatBatch[T any](ctx context.Context, ch <-chan []T, batchSize int, fn func([]T))

FlatBatch reads from a channel of slices, flats values, and calls fn with a slice of batchSize.

func FlatBatchFilter

func FlatBatchFilter[T, V any](ctx context.Context, ch <-chan []T, batchSize int, filter func(T) V, fn func([]V))

FlatBatchFilter reads from a channel of slices, flats values, filters values, and calls fn with a slice of batchSize.