Versions in this module Expand all Collapse all v0 v0.6.1 Aug 17, 2024 v0.6.0 Aug 14, 2024 Changes in this version + type UnboundedBacklog struct + func NewUnboundedBacklog[V any]() *UnboundedBacklog[V] + func (ub *UnboundedBacklog[V]) Close() + func (ub *UnboundedBacklog[V]) Get() <-chan V + func (ub *UnboundedBacklog[V]) IsClosed() bool + func (ub *UnboundedBacklog[V]) Load() + func (ub *UnboundedBacklog[V]) Put(t V) + type UnboundedRing struct + func NewUnboundedRing[T any](ctx context.Context) *UnboundedRing[T] + func (r *UnboundedRing[T]) Close() + func (r *UnboundedRing[T]) Get() <-chan T + func (r *UnboundedRing[T]) IsClosed() bool + func (r *UnboundedRing[T]) Put(v ...T) error
Go to main page