(topic string)
| 203 | } |
| 204 | |
| 205 | func (s *Session) delSub(topic string) { |
| 206 | if s.multi != nil { |
| 207 | s.multi.delSub(topic) |
| 208 | return |
| 209 | } |
| 210 | s.subsLock.Lock() |
| 211 | delete(s.subs, topic) |
| 212 | s.subsLock.Unlock() |
| 213 | } |
| 214 | |
| 215 | func (s *Session) countSub() int { |
| 216 | if s.multi != nil { |