(session sockjs.Session)
| 278 | } |
| 279 | |
| 280 | func (k *Kite) sockjsHandler(session sockjs.Session) { |
| 281 | defer session.Close(3000, "Go away!") |
| 282 | |
| 283 | // This Client also handles the connected client. |
| 284 | // Since both sides can send/receive messages the client code is reused here. |
| 285 | c := k.NewClient("") |
| 286 | defer c.Close() |
| 287 | |
| 288 | c.setSession(session) |
| 289 | c.wg.Add(1) |
| 290 | go c.sendHub() |
| 291 | |
| 292 | k.callOnConnectHandlers(c) |
| 293 | c.callOnConnectHandlers() |
| 294 | |
| 295 | // Run after methods are registered and delegate is set |
| 296 | c.readLoop() |
| 297 | |
| 298 | c.callOnDisconnectHandlers() |
| 299 | k.callOnDisconnectHandlers(c) |
| 300 | } |
| 301 | |
| 302 | // OnConnect registers a callbacks which is called when a Kite connects |
| 303 | // to the k Kite. |
no test coverage detected