(chatID uuid.UUID, message string)
| 4909 | } |
| 4910 | |
| 4911 | func subscribeWithInitialError(chatID uuid.UUID, message string) ( |
| 4912 | []codersdk.ChatStreamEvent, |
| 4913 | <-chan codersdk.ChatStreamEvent, |
| 4914 | func(), |
| 4915 | bool, |
| 4916 | ) { |
| 4917 | events := make(chan codersdk.ChatStreamEvent) |
| 4918 | close(events) |
| 4919 | return []codersdk.ChatStreamEvent{{ |
| 4920 | Type: codersdk.ChatStreamEventTypeError, |
| 4921 | ChatID: chatID, |
| 4922 | Error: &codersdk.ChatError{Message: message}, |
| 4923 | }}, events, func() {}, true |
| 4924 | } |
| 4925 | |
| 4926 | func (p *Server) Subscribe( |
| 4927 | ctx context.Context, |