(connectionId string)
| 270 | } |
| 271 | |
| 272 | func (c *ClientImpl) UnregisterSSEChannel(connectionId string) { |
| 273 | c.SSEChannelsLock.Lock() |
| 274 | defer c.SSEChannelsLock.Unlock() |
| 275 | |
| 276 | if ch, exists := c.SSEChannels[connectionId]; exists { |
| 277 | close(ch) |
| 278 | delete(c.SSEChannels, connectionId) |
| 279 | } |
| 280 | } |
| 281 | |
| 282 | func (c *ClientImpl) SendSSEvent(event ssEvent) error { |
| 283 | if c.GetIsDone() { |