websocket: remove channel buffers
This commit is contained in:
parent
86f41c8027
commit
99ed8dc9a9
|
@ -87,9 +87,9 @@ func (h *Handler) listenForServerEvents(ctx context.Context) error {
|
||||||
ctx, cancel := context.WithCancel(ctx)
|
ctx, cancel := context.WithCancel(ctx)
|
||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
||||||
eventChan := make(chan events.Event, 8)
|
eventChan := make(chan events.Event)
|
||||||
logOutput := make(chan []byte, 8)
|
logOutput := make(chan []byte)
|
||||||
installOutput := make(chan []byte, 8)
|
installOutput := make(chan []byte)
|
||||||
h.server.Events().On(eventChan, e...)
|
h.server.Events().On(eventChan, e...)
|
||||||
h.server.LogSink().On(logOutput)
|
h.server.LogSink().On(logOutput)
|
||||||
h.server.InstallSink().On(installOutput)
|
h.server.InstallSink().On(installOutput)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user