(connectionId string)
| 261 | } |
| 262 | |
| 263 | func (c *ClientImpl) RegisterSSEChannel(connectionId string) chan ssEvent { |
| 264 | c.SSEChannelsLock.Lock() |
| 265 | defer c.SSEChannelsLock.Unlock() |
| 266 | |
| 267 | ch := make(chan ssEvent, 100) |
| 268 | c.SSEChannels[connectionId] = ch |
| 269 | return ch |
| 270 | } |
| 271 | |
| 272 | func (c *ClientImpl) UnregisterSSEChannel(connectionId string) { |
| 273 | c.SSEChannelsLock.Lock() |