| 5618 | } |
| 5619 | |
| 5620 | func (p *Server) publishRetry(chatID uuid.UUID, payload *codersdk.ChatStreamRetry) { |
| 5621 | if payload == nil { |
| 5622 | return |
| 5623 | } |
| 5624 | p.publishEvent(chatID, codersdk.ChatStreamEvent{ |
| 5625 | Type: codersdk.ChatStreamEventTypeRetry, |
| 5626 | Retry: payload, |
| 5627 | }) |
| 5628 | p.publishChatStreamNotify(chatID, coderdpubsub.ChatStreamNotifyMessage{ |
| 5629 | Retry: payload, |
| 5630 | }) |
| 5631 | } |
| 5632 | |
| 5633 | func (p *Server) publishError(chatID uuid.UUID, classified chaterror.ClassifiedError) { |
| 5634 | payload := chaterror.TerminalErrorPayload(classified) |