| 509 | } |
| 510 | |
| 511 | func (t *Topic) handleTopicTimeout(hub *Hub, currentUA string, uaTimer, defrNotifTimer *time.Timer) { |
| 512 | // Topic timeout |
| 513 | hub.unreg <- &topicUnreg{rcptTo: t.name} |
| 514 | defrNotifTimer.Stop() |
| 515 | switch t.cat { |
| 516 | case types.TopicCatMe: |
| 517 | uaTimer.Stop() |
| 518 | t.presUsersOfInterest("off", currentUA) |
| 519 | case types.TopicCatGrp: |
| 520 | t.presSubsOffline("off", nilPresParams, nilPresFilters, nilPresFilters, "", false) |
| 521 | } |
| 522 | } |
| 523 | |
| 524 | func (t *Topic) handleTopicTermination(sd *shutDown) { |
| 525 | // Handle four cases: |