time_queue

package

v0.0.0-...-d2f97bb Latest Latest Go to latest Published: Sep 5, 2025 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Item[T any] struct {
	Time  time.Time
	Value T
}

type Queue[T any] struct {
	// contains filtered or unexported fields
}

func New[T any]() *Queue[T]

func (q *Queue[T]) Dispatch(ctx context.Context) iter.Seq[Item[T]]

func (q *Queue[T]) Flush(now time.Time) iter.Seq[Item[T]]

func (q *Queue[T]) Schedule(item Item[T]) (dispatchUpdater func(updater func(Item[T]) Item[T]))