ctx, cancel := context.WithCancel(ws.Request().Context())
defer cancel()
- incoming := eventSource.NewSink()
- defer incoming.Stop()
-
queue := make(chan interface{}, h.QueueSize)
h.mtx.Lock()
h.lastDelay[queue] = 0
ticker := time.NewTicker(h.PingTimeout)
defer ticker.Stop()
+ incoming := eventSource.NewSink()
+ defer incoming.Stop()
+
for {
select {
case <-ctx.Done():