fixes the issue #7

alash3al · alash3al · commit 0b086f8a5487 · 2018-03-27T19:03:25.000+02:00
diff --git a/server.go b/server.go
@@ -72,7 +72,6 @@ func WSHandler(c echo.Context) error {
 		select {
 		case <-closeCh:
 			closed = true
-			close(closeCh)
 			Broker.Detach(subscriber)
 			TriggerWebhook(Event{Action: "disconnect", Key: key})
 		case data := <-subscriber.GetMessages():
@@ -112,7 +111,7 @@ func goRoutineAction(conn *websocket.Conn, closeCh chan bool, subscriber *pubsub
 				Broker.Unsubscribe(subscriber, action.Value)
 			}
 		}
-		closeCh <- true
+		close(closeCh)
 	})()
 }
 

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,6 @@ func WSHandler(c echo.Context) error {`
`72`	`72`	`select {`
`73`	`73`	`case <-closeCh:`
`74`	`74`	`closed = true`
`75`		`- close(closeCh)`
`76`	`75`	`Broker.Detach(subscriber)`
`77`	`76`	`TriggerWebhook(Event{Action: "disconnect", Key: key})`
`78`	`77`	`case data := <-subscriber.GetMessages():`
`@@ -112,7 +111,7 @@ func goRoutineAction(conn websocket.Conn, closeCh chan bool, subscriber pubsub`
`112`	`111`	`Broker.Unsubscribe(subscriber, action.Value)`
`113`	`112`	`}`
`114`	`113`	`}`
`115`		`- closeCh <- true`
	`114`	`+ close(closeCh)`
`116`	`115`	`})()`
`117`	`116`	`}`
`118`	`117`