Versions in this module Expand all Collapse all v0 v0.7.0 Dec 12, 2024 Changes in this version + type RWLocker struct + func NewRWLocker[T any](value T) RWLocker[T] + func (this *RWLocker[T]) Borrow() (T, func()) + func (this *RWLocker[T]) RBorrow() (T, func()) + func (this *RWLocker[T]) Set(value T) v0.6.0 Dec 5, 2024 Changes in this version + func Combine[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) <-chan T + func Select[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) (int, T, bool) + type ChannelRecv interface + type Locker struct + func NewLocker[T any](value T) Locker[T] + func (this *Locker[T]) Borrow() (T, func()) + func (this *Locker[T]) Set(value T) v0.5.0 Nov 11, 2024 Changes in this version + type Error string + const ErrAlreadyClosed + func (err Error) Error() string + type Gate struct + func NewBufferedGate[T any](buffer int) Gate[T] + func NewGate[T any]() Gate[T] + func (this *Gate[T]) Cap() int + func (this *Gate[T]) Close() error + func (this *Gate[T]) Len() int + func (this *Gate[T]) Open() bool + func (this *Gate[T]) Receive() <-chan T + func (this *Gate[T]) Reset() error + func (this *Gate[T]) Send(item T) bool