internal

type ChannelMultiplexer[T any] interface {
	// In adds the given input channel reading.
	In() chan<- T

	AddIn(chan T)

	// Out returns a new output channel that receives from all input channels.
	Out() <-chan T

	// AddOut registers the given output channel to receive from all input channels.
	AddOut(chan T)

	// Run starts multiplexing of all input channels to all output channels.
	// Once run is called, cannot be modified and will panic.
	Run(context.Context) error
}

type Multiplex interface {
	In() chan interface{}
	Out() chan interface{}
	Do(context.Context) error
}