diff --git a/server.go b/server.go index 1e25592..d7903aa 100644 --- a/server.go +++ b/server.go @@ -90,7 +90,7 @@ func subHandler(w http.ResponseWriter, r *http.Request) { } }() - theHub.Sub(sub) + go theHub.Sub(sub) res := <-result w.Header().Set("Queue", res.Queue)