From da7d0ebaeaa8b17b5813d199719b2815044320fa Mon Sep 17 00:00:00 2001 From: "Oliver, Jonathan" Date: Tue, 3 Jun 2014 22:04:27 -0600 Subject: [PATCH] Revised signature. --- example/main.go | 6 +++++- wireup.go | 6 ++---- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/example/main.go b/example/main.go index 53f6ad9..62a4365 100644 --- a/example/main.go +++ b/example/main.go @@ -20,7 +20,11 @@ var ring = [BufferSize]int64{} func main() { runtime.GOMAXPROCS(2) - controller := disruptor.Configure(BufferSize, SampleConsumer{}).Build() + controller := disruptor. + Configure(BufferSize). + WithConsumerGroup(SampleConsumer{}). + Build() + controller.Start() started := time.Now() diff --git a/wireup.go b/wireup.go index 57f3f81..7a38a57 100644 --- a/wireup.go +++ b/wireup.go @@ -10,14 +10,12 @@ type ( } ) -func Configure(capacity int64, consumers ...Consumer) Wireup { - this := Wireup{ +func Configure(capacity int64) Wireup { + return Wireup{ capacity: capacity, groups: [][]Consumer{}, cursors: []*Cursor{NewCursor()}, } - - return this.WithConsumerGroup(consumers...) } func (this Wireup) WithConsumerGroup(consumers ...Consumer) Wireup {