buffer

Documentation

Index

• type Buffer
  • func New[T any]() *Buffer[T]
  • func (b *Buffer[T]) Close()
  • func (b *Buffer[T]) IsClosed() bool
  • func (b *Buffer[T]) IsEmpty() bool
  • func (b *Buffer[T]) Pop() (T, bool)
  • func (b *Buffer[T]) Push(val T)
• type Iterator
  • func NewIterator[T any](buffer *Buffer[T], nextChan chan<- *Iterator[T], closeChan chan<- *Iterator[T]) *Iterator[T]
  • func (iter *Iterator[T]) Close() error
  • func (iter *Iterator[T]) End()
  • func (iter *Iterator[T]) Err() error
  • func (iter *Iterator[T]) Get() (T, error)
  • func (iter *Iterator[T]) Next() bool
  • func (iter *Iterator[T]) SendErr(err error)
  • func (iter *Iterator[T]) SendItem(val T)

Types

type Buffer

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

func New

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

func (*Buffer[T]) Close

func (b *Buffer[T]) Close()

func (*Buffer[T]) IsClosed

func (b *Buffer[T]) IsClosed() bool

func (*Buffer[T]) IsEmpty

func (b *Buffer[T]) IsEmpty() bool

func (*Buffer[T]) Pop

func (b *Buffer[T]) Pop() (T, bool)

func (*Buffer[T]) Push

func (b *Buffer[T]) Push(val T)

type Iterator

type Iterator[T any] struct {
	Buffer *Buffer[T]
	// contains filtered or unexported fields
}

func NewIterator

func NewIterator[T any](buffer *Buffer[T], nextChan chan<- *Iterator[T], closeChan chan<- *Iterator[T]) *Iterator[T]

func (*Iterator[T]) Close

func (iter *Iterator[T]) Close() error

func (*Iterator[T]) End

func (iter *Iterator[T]) End()

func (*Iterator[T]) Err

func (iter *Iterator[T]) Err() error

func (*Iterator[T]) Get

func (iter *Iterator[T]) Get() (T, error)

func (*Iterator[T]) Next

func (iter *Iterator[T]) Next() bool

func (*Iterator[T]) SendErr

func (iter *Iterator[T]) SendErr(err error)

func (*Iterator[T]) SendItem

func (iter *Iterator[T]) SendItem(val T)