consumer.go

package disruptor

type Consumer interface {
	Consume(int64, int64) int64
}