Skip to content

Commit

Permalink
Merge pull request #17 from euskadi31/fix/bad-flush
Browse files Browse the repository at this point in the history
fix: bad flush condition
  • Loading branch information
euskadi31 authored May 2, 2023
2 parents b4cdece + 74abf0a commit 6bfe745
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion client.go
Original file line number Diff line number Diff line change
Expand Up @@ -101,7 +101,7 @@ func (c *client) loop() {
case event := <-c.msgs:
c.events = append(c.events, event)

if len(c.events) == cap(c.events) {
if len(c.events) == c.bufferSize {
c.flush()
}

Expand Down

0 comments on commit 6bfe745

Please sign in to comment.