()
| 107 | } |
| 108 | |
| 109 | func (s *Subscribers) AbortWait() { |
| 110 | s.waitAborted = true |
| 111 | for wait := range s.waits { |
| 112 | wait.Resolve() |
| 113 | delete(s.waits, wait) |
| 114 | } |
| 115 | } |
| 116 | |
| 117 | func (s *Subscribers) Find(id string) ISubscriber { |
| 118 | for sub := range s.public { |