util

Documentation

Index

• func AllClosed(channels ...<-chan struct{}) <-chan struct{}
• func AllDone(components ...module.ReadyDoneAware) <-chan struct{}
• func AllReady(components ...module.ReadyDoneAware) <-chan struct{}

Functions

func AllClosed

func AllClosed(channels ...<-chan struct{}) <-chan struct{}

AllClosed returns a channel that is closed when all input channels are closed.

func AllDone

func AllDone(components ...module.ReadyDoneAware) <-chan struct{}

AllDone calls Done on all input components and returns a channel that is closed when all input components are done.

func AllReady

func AllReady(components ...module.ReadyDoneAware) <-chan struct{}

AllReady calls Ready on all input components and returns a channel that is closed when all input components are ready.