(currentUA string)
| 500 | } |
| 501 | |
| 502 | func (t *Topic) handleUATimerEvent(currentUA string) { |
| 503 | // Publish user agent changes after a delay |
| 504 | if currentUA == "" || currentUA == t.userAgent { |
| 505 | return |
| 506 | } |
| 507 | t.userAgent = currentUA |
| 508 | t.presUsersOfInterest("ua", t.userAgent) |
| 509 | } |
| 510 | |
| 511 | func (t *Topic) handleTopicTimeout(hub *Hub, currentUA string, uaTimer, defrNotifTimer *time.Timer) { |
| 512 | // Topic timeout |