usync

Documentation

Index

• func Combine[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) <-chan T
• func Select[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) (int, T, bool)
• type ChannelRecv
• type Error
  • func (err Error) Error() string
• type Gate
  • func NewBufferedGate[T any](buffer int) Gate[T]
  • func NewGate[T any]() Gate[T]
  • func (this *Gate[T]) Cap() int
  • func (this *Gate[T]) Close() error
  • func (this *Gate[T]) Len() int
  • func (this *Gate[T]) Open() bool
  • func (this *Gate[T]) Receive() <-chan T
  • func (this *Gate[T]) Reset() error
  • func (this *Gate[T]) Send(item T) bool
• type Locker
  • func NewLocker[T any](value T) Locker[T]
  • func (this *Locker[T]) Borrow() (T, func())
  • func (this *Locker[T]) Set(value T)

Functions

func Combine

func Combine[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) <-chan T

Combine returns a channel that continuously returns the result of the select until all input sources are exhauste, or the context is canceled.

func Select

func Select[T any, C ChannelRecv[T]](ctx context.Context, channels ...C) (int, T, bool)

A type-safe wrapper around reflect.Select. Taken from: https://stackoverflow.com/questions/19992334

Types

type ChannelRecv

type ChannelRecv[T any] interface {
	~chan T | ~<-chan T
}

ChannelRecv is a type constraint that includes all channel types that can be recieved from.

type Error

type Error string

Error defines errors that this package can produce

const (
	ErrAlreadyClosed Error = "AlreadyClosed"
)

func (Error) Error

func (err Error) Error() string

Error fullfills the error interface.

type Gate

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

Gate wraps a channel and allows the receiver to abruptly stop receiving messages without causing the sender to lock up.

func NewBufferedGate

func NewBufferedGate[T any](buffer int) Gate[T]

NewBufferedGate creates a new gate with a buffer.

func NewGate

func NewGate[T any]() Gate[T]

NewGate creates a new gate with no buffer.

func (*Gate[T]) Cap

func (this *Gate[T]) Cap() int

Cap returns the amount of items the channel can hold.

func (*Gate[T]) Close

func (this *Gate[T]) Close() error

Close closes the gate, drains all remaining messages, and closes the channel.

func (*Gate[T]) Len

func (this *Gate[T]) Len() int

Len returns the amount of items in the channel.

func (*Gate[T]) Open

func (this *Gate[T]) Open() bool

Open returns whether the gate is open.

func (*Gate[T]) Receive

func (this *Gate[T]) Receive() <-chan T

Receive returns a receive-only channel that can be used to receive items.

func (*Gate[T]) Reset

func (this *Gate[T]) Reset() error

Reset re-opens the gate if it is closed, and creates a new channel.

func (*Gate[T]) Send

func (this *Gate[T]) Send(item T) bool

Send sends and item to the channel, returning whether the item was sent.

type Locker

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

Locker guards access to a value

func NewLocker

func NewLocker[T any](value T) Locker[T]

NewLocker creates a new locker with the specified value.

func (*Locker[T]) Borrow

func (this *Locker[T]) Borrow() (T, func())

Borrow borrows the value from the locker, and returns a function that must immediately be deferred, like this:

value, done := locker.Borrow()
defer done()

From the time Borrow is called to the time the done function is called, it is safe to access the locked object from within the current goroutine.

func (*Locker[T]) Set

func (this *Locker[T]) Set(value T)

Set sets the value of the locker.