We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6a8ac6c commit 22e2b5cCopy full SHA for 22e2b5c
client.go
@@ -129,10 +129,8 @@ func (c *Client) run() {
129
130
// flusher amortizes flushing costs for high activity SSE channels
131
func (c *Client) flusher() {
132
- ticker := time.NewTicker(100 * time.Millisecond)
133
-
134
for {
135
- <-ticker.C
+ time.Sleep(100 * time.Millisecond)
136
c.lock.Lock()
137
if c.closed {
138
break
@@ -144,6 +142,5 @@ func (c *Client) flusher() {
144
142
c.lock.Unlock()
145
143
}
146
147
- ticker.Stop()
148
c.waiter.Done()
149
0 commit comments