diff --git a/ring.go b/ring.go index 9656b2a..0e874c6 100644 --- a/ring.go +++ b/ring.go @@ -14,7 +14,6 @@ type Ring struct { cur uint64 consumers []*RingConsumer - closed bool } // NewRing creates a new ring buffer. @@ -27,10 +26,6 @@ func NewRing(capacity int) *Ring { // 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 r.cur++ @@ -40,14 +35,6 @@ func (r *Ring) Cur() uint64 { return r.cur } -func (r *Ring) Close() { - if r.closed { - panic("soju: Ring.Close called twice") - } - - r.closed = true -} - // NewConsumer creates a new ring buffer consumer. // // If seq is nil, the consumer will get messages starting from the last diff --git a/user.go b/user.go index a008c00..018009b 100644 --- a/user.go +++ b/user.go @@ -363,7 +363,6 @@ func (u *user) deleteNetwork(id int64) error { }) net.Stop() - net.ring.Close() u.networks = append(u.networks[:i], u.networks[i+1:]...) return nil }