chanx

type Unbounded ¶

type Unbounded[T any] struct {
	// contains filtered or unexported fields
}

Unbounded 是一个无界 channel：发送端永不阻塞（值缓存在内部切片中）， 接收端从 Out() 读取，保持 FIFO 顺序。适合事件总线、日志队列等 "生产不可阻塞、消费可能滞后" 的场景。

使用：

u := chanx.NewUnbounded[int]()
u.In() <- 1
v := <-u.Out()
u.Close() // 关闭后 Out() 读完剩余值再关闭

func NewUnbounded[T any]() *Unbounded[T]

func (u *Unbounded[T]) Close()

func (u *Unbounded[T]) In() chan<- T

func (u *Unbounded[T]) Out() <-chan T