package syncs

import "sigs.k8s.io/controller-runtime/pkg/internal/syncs"

Index ¶

• func MergeChans[T any](chans ...<-chan T) (<-chan T, context.CancelFunc)

Functions ¶

func MergeChans ¶

func MergeChans[T any](chans ...<-chan T) (<-chan T, context.CancelFunc)

MergeChans returns a channel that is closed when any of the input channels are signaled. The caller must call the returned CancelFunc to ensure no resources are leaked.

Source Files ¶

syncs.go