last_in_one_out_queue

Documentation

Index

• type LastInOneOutQueue
  • func New[T any]() *LastInOneOutQueue[T]
  • func (q *LastInOneOutQueue[T]) Enqueue(item T)
  • func (q *LastInOneOutQueue[T]) Item() <-chan T
  • func (q *LastInOneOutQueue[T]) Run(ctx context.Context)

Types

type LastInOneOutQueue

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

func New

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

func (*LastInOneOutQueue[T]) Enqueue

func (q *LastInOneOutQueue[T]) Enqueue(item T)

Enqueue puts the item in the queue. It replaces any previously-queued item.

func (*LastInOneOutQueue[T]) Item

func (q *LastInOneOutQueue[T]) Item() <-chan T

Item returns the channel on which queued items can be dequeued.

func (*LastInOneOutQueue[T]) Run

func (q *LastInOneOutQueue[T]) Run(ctx context.Context)