|
|
@ -88,6 +88,7 @@ func (m *Melody) HandleRequest(w http.ResponseWriter, r *http.Request) { |
|
|
|
|
|
|
|
session := &Session{ |
|
|
|
Request: r, |
|
|
|
Params: make(map[string]interface{}), |
|
|
|
conn: conn, |
|
|
|
output: make(chan *envelope, m.Config.MessageBufferSize), |
|
|
|
melody: m, |
|
|
@ -95,7 +96,7 @@ func (m *Melody) HandleRequest(w http.ResponseWriter, r *http.Request) { |
|
|
|
|
|
|
|
m.hub.register <- session |
|
|
|
|
|
|
|
go m.connectHandler(session) |
|
|
|
m.connectHandler(session) |
|
|
|
|
|
|
|
go session.writePump() |
|
|
|
|
|
|
|