From f4aa05af66a846d7399639291b839b3b81d75c7c Mon Sep 17 00:00:00 2001 From: Simon Ser Date: Tue, 7 Apr 2020 14:46:31 +0200 Subject: [PATCH] Remove Ring.consumers We don't need to keep track of consumers anymore. --- ring.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/ring.go b/ring.go index 50714e1..9eacd8b 100644 --- a/ring.go +++ b/ring.go @@ -11,9 +11,7 @@ import ( type Ring struct { buffer []*irc.Message cap uint64 - - cur uint64 - consumers []*RingConsumer + cur uint64 } // NewRing creates a new ring buffer. @@ -41,9 +39,7 @@ func (r *Ring) Cur() uint64 { // The consumer will get messages starting from the specified history sequence // number (see Ring.Cur). func (r *Ring) NewConsumer(seq uint64) *RingConsumer { - consumer := &RingConsumer{ring: r, cur: seq} - r.consumers = append(r.consumers, consumer) - return consumer + return &RingConsumer{ring: r, cur: seq} } // RingConsumer is a ring buffer consumer.