fanin

Documentation

Index

• func Errors(errs ...<-chan error) (_ <-chan error, stop func())
• func ErrorsContext(ctx context.Context, errs ...<-chan error) <-chan error

Functions

func Errors

func Errors(errs ...<-chan error) (_ <-chan error, stop func())

Errors accepts multiple error channels and returns a single error channel. When the returned stop function is called or every input channel is closed, the returned error channel is closed.

If len(errs) == 0, Errors returns a closed error channel.

Multiple calls to stop have no effect.

func ErrorsContext

func ErrorsContext(ctx context.Context, errs ...<-chan error) <-chan error

Errors accepts a Context and multiple error channels and returns a single error channel. When ctx is canceled or every input channel is closed, the returned error channel is closed.

If len(errs) == 0, Errors returns a closed error channel.