Changeset 241 in code for trunk/ring.go

Timestamp:

Apr 7, 2020, 12:42:13 PM (5 years ago)

Author:

contact

Message:

Remove Ring.Close

This is unused.

File:

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

trunk/ring.go

@@ -15 +15 @@
         cur       uint64
         consumers []*RingConsumer
-        closed    bool
 }
 
@@ -28 +27 @@
 // Produce appends a new message to the ring buffer.
 func (r *Ring) Produce(msg *irc.Message) {
-        if r.closed {
-                panic("soju: Ring.Produce called after Close")
-        }
-
         i := int(r.cur % r.cap)
         r.buffer[i] = msg
@@ -39 +34 @@
 func (r *Ring) Cur() uint64 {
         return r.cur
-}
-
-func (r *Ring) Close() {
-        if r.closed {
-                panic("soju: Ring.Close called twice")
-        }
-
-        r.closed = true
 }