queue

Feb 10, 2026

Changes in this version

type Listener

+ Consume func() (x X, ok bool)

Feb 9, 2026

Changes in this version

type Listener

+ Wait func() (ch <-chan X)

Oct 17, 2025

Changes in this version

type Listener

+ BatchIter func() (it iter.Seq[[]X])

+ type PullFn func(d time.Duration) (more []X, ok bool)

type Queue

+ Pull func(ctx context.Context) (fn PullFn[X])

Jul 4, 2025

Changes in this version

type Listener

+ Context func() context.Context

Feb 27, 2025

Changes in this version

type Listener

+ Iter func() iter.Seq[X]

Dec 4, 2024

Changes in this version

+ type Listener interface

+ Batch func() []X

+ Next func() (X, bool)

+ Peek func() (X, bool)

Jan 9, 2024

Changes in this version

+ type Queue interface

+ Join func(ctx context.Context) QueueListener[X]

+ Push func(all ...X) bool

+ func New[X any]() Queue[X]

+ type QueueListener interface

+ Batch func() []X

+ Next func() (X, bool)