publishChatPubsubEvents broadcasts a lifecycle event for each affected chat.
(chats []database.Chat, kind codersdk.ChatWatchEventKind)
| 5508 | |
| 5509 | // publishChatPubsubEvents broadcasts a lifecycle event for each affected chat. |
| 5510 | func (p *Server) publishChatPubsubEvents(chats []database.Chat, kind codersdk.ChatWatchEventKind) { |
| 5511 | for _, chat := range chats { |
| 5512 | p.publishChatPubsubEvent(chat, kind, nil) |
| 5513 | } |
| 5514 | } |
| 5515 | |
| 5516 | // publishChatPubsubEvent broadcasts a chat lifecycle event via PostgreSQL |
| 5517 | // pubsub so that all replicas can push updates to watching clients. |
no test coverage detected