package disruptor

type Barrier interface {
	LoadBarrier(int64) int64
}

func NewBarrier(upstream ...*Cursor) Barrier {
	if len(upstream) == 0 {
		panic("At least one upstream cursor is required.")
	} else if len(upstream) == 1 {
		return upstream[0] // TODO: better performance through the interface by dereferencing?
	} else {
		return NewCompositeBarrier(upstream...)
	}
}