(streamId string)
| 228 | } |
| 229 | |
| 230 | func (b *Broker) cleanupReader(streamId string) { |
| 231 | b.lock.Lock() |
| 232 | defer b.lock.Unlock() |
| 233 | |
| 234 | delete(b.readers, streamId) |
| 235 | delete(b.readerRoutes, streamId) |
| 236 | delete(b.readerErrorSentTime, streamId) |
| 237 | } |
| 238 | |
| 239 | func (b *Broker) cleanupWriter(streamId string) { |
| 240 | b.lock.Lock() |