channel

Documentation

Index

• func Multicast[T any](parent context.Context, in <-chan T, outs ...chan<- T) context.CancelFunc
• func Send[T any](ctx context.Context, value T, c chan<- T) error

Functions

func Multicast

func Multicast[T any](parent context.Context, in <-chan T, outs ...chan<- T) context.CancelFunc

Multicast dispatch the input channel message to the multiple others

func Send

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

Send reduces boilerplate for blocking unbuffered channels and ensures propagation of context termination