Changeset 243 in code for trunk/ring.go

Timestamp:

Apr 7, 2020, 12:46:31 PM (5 years ago)

Author:

contact

Message:

Remove Ring.consumers

We don't need to keep track of consumers anymore.

File:

• trunk/ring.go (modified) (2 diffs)

trunk/ring.go

@@ -12 +12 @@
         buffer []*irc.Message
         cap    uint64
-
-        cur       uint64
-        consumers []*RingConsumer
+        cur    uint64
 }
 
@@ -42 +40 @@
 // 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}
 }