Function NewUnbounded

internal/buffer/unbounded.go:48–50

NewUnbounded returns a new instance of Unbounded.

()

// NewUnbounded returns a new instance of Unbounded.
func NewUnbounded() *Unbounded {
	return &Unbounded{c: make(chan any, 1)}
}

var errBufferClosed = errors.New("Put called on closed buffer.Unbounded")