Versions in this module Expand all Collapse all v1 v1.1.0 Mar 6, 2025 Changes in this version + func WithBaseCapacity[T any](n int) func(*ChanQueue[T]) + func WithInputRdOnly[T any](in <-chan T) func(*ChanQueue[T]) v1.0.0 Nov 24, 2024 Changes in this version + func WithCapacity[T any](n int) func(*ChanQueue[T]) + func WithInput[T any](in chan T) func(*ChanQueue[T]) + func WithOutput[T any](out chan T) func(*ChanQueue[T]) + type ChanQueue struct + func NewRing[T any](options ...Option[T]) *ChanQueue[T] + func New[T any](options ...Option[T]) *ChanQueue[T] + func (cq *ChanQueue[T]) Cap() int + func (cq *ChanQueue[T]) Close() + func (cq *ChanQueue[T]) In() chan<- T + func (cq *ChanQueue[T]) Len() int + func (cq *ChanQueue[T]) Out() <-chan T + func (cq *ChanQueue[T]) Shutdown() + type Option func(*ChanQueue[T])
Go to main page