Changeset 232 in code for trunk/ring.go

Timestamp:

Apr 6, 2020, 4:33:26 PM (5 years ago)

Author:

contact

Message:

Remove RingConsumer.Close

This is now unused.

File:

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

trunk/ring.go

@@ -71 +71 @@
 // RingConsumer is a ring buffer consumer.
 type RingConsumer struct {
-        ring   *Ring
-        cur    uint64
-        closed bool
+        ring *Ring
+        cur  uint64
 }
 
@@ -87 +86 @@
 // message is returned if no message is available.
 func (rc *RingConsumer) Peek() *irc.Message {
-        if rc.closed {
-                panic("soju: RingConsumer.Peek called after Close")
-        }
-
         diff := rc.diff()
         if diff == 0 {
@@ -116 +111 @@
         return msg
 }
-
-// Close stops consuming messages. The consumer channel will be closed. The
-// current history sequence number is returned. It can be provided later as an
-// argument to Ring.NewConsumer to resume the message stream.
-func (rc *RingConsumer) Close() uint64 {
-        for i := range rc.ring.consumers {
-                if rc.ring.consumers[i] == rc {
-                        rc.ring.consumers = append(rc.ring.consumers[:i], rc.ring.consumers[i+1:]...)
-                        break
-                }
-        }
-
-        rc.closed = true
-        return rc.cur
-}