concurrency

Documentation

Index

• func Or[T any](channels ...<-chan T) <-chan T
• func OrDone[T any](done <-chan bool, c <-chan T) <-chan T
• func OrDoneCtx[T any](ctx context.Context, c <-chan T) <-chan T
• func Slots[T any](ctx context.Context, in <-chan T, n int) chan chan T

Functions

func Or

func Or[T any](channels ...<-chan T) <-chan T

func OrDone

func OrDone[T any](done <-chan bool, c <-chan T) <-chan T

func OrDoneCtx

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

func Slots

func Slots[T any](ctx context.Context, in <-chan T, n int) chan chan T