RWSafe

Feb 26, 2024

Changes in this version

type Buffer

+ func (b *Buffer[T]) GetReceiveChannel() <-chan T

+ func (b *Buffer[T]) GetSendChannel() chan<- T

Feb 7, 2024

Changes in this version

type RWSafe

+ func (rw *RWSafe[T]) DoRead(f func(T))

+ func (rw *RWSafe[T]) DoWrite(f func(*T))

Jan 12, 2024

Changes in this version

type RWSafe

+ func (rw *RWSafe[T]) Cleanup()

Jan 6, 2024

Changes in this version

+ type Buffer struct

+ func (b *Buffer[T]) CleanBuffer()

+ func (b *Buffer[T]) Cleanup()

+ func (b *Buffer[T]) Init(bufferSize int) (chan<- T, <-chan T)

+ func (b *Buffer[T]) Wait()

+ type RWSafe struct

+ func NewRWSafe[T any](value T) *RWSafe[T]

+ func (rw *RWSafe[T]) Get() T

+ func (rw *RWSafe[T]) Set(value T)

+ type RWSafeQueue struct

+ func NewRWSafeQueue[T any](values ...T) *RWSafeQueue[T]

+ func (b *RWSafeQueue[T]) Clear()

+ func (b *RWSafeQueue[T]) Dequeue() T

+ func (b *RWSafeQueue[T]) Enqueue(value T)

+ func (b *RWSafeQueue[T]) IsEmpty() bool