sad/soju
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Remove Ring.consumers

Browse Source 
We don't need to keep track of consumers anymore.
This commit is contained in:
Simon Ser 2020-04-07 14:46:31 +02:00
parent dd08acc3ea
commit f4aa05af66
No known key found for this signature in database
GPG Key ID: 0FDE7BE0E88F5E48
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ring.go
View File

@ -11,9 +11,7 @@ import (
type Ring struct { type Ring struct {
buffer []*irc.Message buffer []*irc.Message
cap uint64 cap uint64
cur uint64
cur uint64
consumers []*RingConsumer
} }
// NewRing creates a new ring buffer. // 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 // The consumer will get messages starting from the specified history sequence
// number (see Ring.Cur). // number (see Ring.Cur).
func (r *Ring) NewConsumer(seq uint64) *RingConsumer { func (r *Ring) NewConsumer(seq uint64) *RingConsumer {
consumer := &RingConsumer{ring: r, cur: seq} return &RingConsumer{ring: r, cur: seq}
r.consumers = append(r.consumers, consumer)
return consumer
} }
// RingConsumer is a ring buffer consumer. // RingConsumer is a ring buffer consumer.