Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2023 Changes in this version + type FixedSizeObserver struct + func NewFixedSizeObserver(ctx context.Context, maxSize int, waitElementsInterval time.Duration, ...) *FixedSizeObserver[T] + func (q *FixedSizeObserver[T]) GetLength() int + func (q *FixedSizeObserver[T]) Publish(element T) + func (q *FixedSizeObserver[T]) Release() + func (q *FixedSizeObserver[T]) Subscribe(ctx context.Context) <-chan T