From 0df82da7a8cd0678ed845f2284b7d3f84ba84687 Mon Sep 17 00:00:00 2001 From: Shulhan Date: Thu, 26 Nov 2020 17:20:31 +0700 Subject: websocket: create buffered channel for running queue This is to fix Stop() method waiting for running channel to be consumed. --- lib/websocket/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/websocket/server.go b/lib/websocket/server.go index e57e5b4d..d7d1bb65 100644 --- a/lib/websocket/server.go +++ b/lib/websocket/server.go @@ -74,7 +74,7 @@ func NewServer(opts *ServerOptions) (serv *Server) { opts: opts, Clients: newClientManager(), routes: newRootRoute(), - running: make(chan struct{}), + running: make(chan struct{}, 1), } opts.init() -- cgit v1.3