chans

package

v0.0.0-test-multiarch Latest Latest Go to latest Published: Jun 7, 2024 License: GPL-3.0 Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrTimeout = errors.New("timeout waiting for chan")
	ErrClosed  = errors.New("chan closed")
	ErrOpen    = errors.New("chan open")
)

func IsClosedWithin[T any](ch <-chan T, wait time.Duration) error

func IsEmptyWithin[T any](src <-chan T, wait time.Duration) error

func RecvContext[T any](ctx context.Context, c <-chan T) (T, error)

RecvContext receives from c unless ctx is Done.

func RecvWithin[T any](src <-chan T, wait time.Duration) (T, error)

func SendContext[T any](ctx context.Context, c chan<- T, v T) error

SendContext sends v on c unless ctx is Done.

func SendWithin[T any](dest chan<- T, value T, wait time.Duration) error

This section is empty.