From 99ed8dc9a98460ba4af94a6cf9395cdd6226a1bf Mon Sep 17 00:00:00 2001 From: Matthew Penner Date: Sat, 22 Jan 2022 12:30:07 -0700 Subject: [PATCH] websocket: remove channel buffers --- router/websocket/listeners.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/router/websocket/listeners.go b/router/websocket/listeners.go index 828e470..aae8855 100644 --- a/router/websocket/listeners.go +++ b/router/websocket/listeners.go @@ -87,9 +87,9 @@ func (h *Handler) listenForServerEvents(ctx context.Context) error { ctx, cancel := context.WithCancel(ctx) defer cancel() - eventChan := make(chan events.Event, 8) - logOutput := make(chan []byte, 8) - installOutput := make(chan []byte, 8) + eventChan := make(chan events.Event) + logOutput := make(chan []byte) + installOutput := make(chan []byte) h.server.Events().On(eventChan, e...) h.server.LogSink().On(logOutput) h.server.InstallSink().On(installOutput)