lo/docs/data/core-bufferwithtimeout.md

name, slug, sourceRef, category, subCategory, signatures, variantHelpers, similarHelpers, position

name	slug	sourceRef	category	subCategory	signatures	variantHelpers	similarHelpers	position
BufferWithTimeout	bufferwithtimeout	channel.go#L214	core	channel	func BufferWithTimeout[T any](ch <-chan T, size int, timeout time.Duration) (collection []T, length int, readTime time.Duration, ok bool) func BatchWithTimeout[T any](ch <-chan T, size int, timeout time.Duration) (collection []T, length int, readTime time.Duration, ok bool)	core#channel#bufferwithtimeout core#channel#batchwithtimeout	core#channel#buffer core#channel#bufferwithcontext core#channel#slicetochannel core#channel#channeltoslice	263

BufferWithTimeout reads up to size items from a channel with timeout.

ch := make(chan int)
go func() {
    time.Sleep(200 * time.Millisecond)
    ch <- 1
}()

items, length, readTime, ok := lo.BufferWithTimeout(ch, 5, 100*time.Millisecond)
// Returns empty slice due to timeout

BatchWithTimeout (Deprecated)

BatchWithTimeout is an alias for BufferWithTimeout.

ch := make(chan float64)
go func() {
    time.Sleep(150 * time.Millisecond)
    ch <- 3.14
}()

batch, length, readTime, ok := lo.BatchWithTimeout(ch, 3, 100*time.Millisecond)
// Returns empty slice due to timeout