chanx

package

v0.1.2 Latest Latest Go to latest Published: Dec 18, 2023 License: MIT Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

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 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.

This section is empty.