diff --git a/channel.go b/channel.go index 6a8c3ca2..5dcac328 100644 --- a/channel.go +++ b/channel.go @@ -214,7 +214,7 @@ func Buffer[T any](ch <-chan T, size int) (collection []T, length int, readTime // Batch creates a slice of n elements from a channel. Returns the slice and the slice length. // -// Deprecated: Use lo.Buffer instead. +// Deprecated: Use [Buffer] instead. func Batch[T any](ch <-chan T, size int) (collection []T, length int, readTime time.Duration, ok bool) { return Buffer(ch, size) } @@ -248,7 +248,7 @@ func BufferWithTimeout[T any](ch <-chan T, size int, timeout time.Duration) (col // BatchWithTimeout creates a slice of n elements from a channel, with timeout. Returns the slice and the slice length. // -// Deprecated: Use lo.BufferWithTimeout instead. +// Deprecated: Use [BufferWithTimeout] instead. func BatchWithTimeout[T any](ch <-chan T, size int, timeout time.Duration) (collection []T, length int, readTime time.Duration, ok bool) { return BufferWithTimeout(ch, size, timeout) } @@ -281,7 +281,7 @@ func FanIn[T any](channelBufferCap int, upstreams ...<-chan T) <-chan T { // ChannelMerge collects messages from multiple input channels into a single buffered channel. // Output messages has no priority. When all upstream channels reach EOF, downstream channel closes. // -// Deprecated: Use lo.FanIn instead. +// Deprecated: Use [FanIn] instead. func ChannelMerge[T any](channelBufferCap int, upstreams ...<-chan T) <-chan T { return FanIn(channelBufferCap, upstreams...) }