mirror of
https://github.com/samber/lo.git
synced 2026-04-23 07:49:50 +08:00
Samuel Berthe
31 lines
769 B
Markdown
31 lines
769 B
Markdown
---
|
|
name: BufferWithTimeout
|
|
slug: bufferwithtimeout
|
|
sourceRef: channel.go#L214
|
|
category: core
|
|
subCategory: channel
|
|
signatures:
|
|
- "func BufferWithTimeout[T any](ch <-chan T, size int, timeout time.Duration) (collection []T, length int, readTime time.Duration, ok bool)"
|
|
variantHelpers:
|
|
- core#channel#bufferwithtimeout
|
|
similarHelpers:
|
|
- core#channel#buffer
|
|
- core#channel#bufferwithcontext
|
|
- core#channel#slicetochannel
|
|
- core#channel#channeltoslice
|
|
position: 263
|
|
---
|
|
|
|
BufferWithTimeout reads up to size items from a channel with timeout.
|
|
|
|
```go
|
|
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
|
|
```
|