diff --git a/example/main.go b/example/main.go
index 3c97749..31c59c7 100644
--- a/example/main.go
+++ b/example/main.go
@@ -32,20 +32,28 @@
 
 const Reservations = 1
 
-// const ReservationMask = -Reservations + 1
-
 func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
 	sequence := disruptor.InitialSequenceValue
 	writer := disruptor.NewWriter(written, upstream, BufferSize)
 	for sequence <= Iterations {
 		sequence += Reservations
-		writer.Reserve(sequence)
+		writer.Await(sequence)
 		ringBuffer[sequence&BufferMask] = sequence
 		writer.Commit(sequence)
 	}
 }
 
 // func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
+// 	sequence := disruptor.InitialSequenceValue
+// 	writer := disruptor.NewWriter(written, upstream, BufferSize)
+// 	for sequence <= Iterations {
+// 		sequence = writer.Reserve(Reservations)
+// 		ringBuffer[sequence&BufferMask] = sequence
+// 		writer.Commit(sequence)
+// 	}
+// }
+
+// func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
 // 	previous := disruptor.InitialSequenceValue
 // 	gate := disruptor.InitialSequenceValue
 
diff --git a/writer.go b/writer.go
index 4ed7dae..d580b8a 100644
--- a/writer.go
+++ b/writer.go
@@ -27,12 +27,19 @@
 	}
 }
 
-func (this *Writer) Reserve(next int64) {
+func (this *Writer) Reserve(count int64) int64 {
+	this.previous += count
+	for this.previous-this.capacity > this.gate {
+		this.gate = this.upstream.Read(0)
+	}
+	return this.previous
+}
+
+func (this *Writer) Await(next int64) {
 	for next-this.capacity > this.gate {
 		this.gate = this.upstream.Read(0)
 	}
 }
-
 func (this *Writer) Commit(sequence int64) {
 	this.written.sequence = sequence
 }