dam

type Dam interface {
	// Flush flushes all channels and return the number of flushed channels
	Flush(err error) uint32

	// Wait blocks until the dam is flushed
	Wait() error

	// Chan returns a channel that's written to when the dam is flushed
	Chan() chan error
}