Function streamMessageAnswerJob

controllers/message_answer.go:100–138

(responseWriter http.ResponseWriter, request *http.Request, job *messageAnswerJob)

}

func streamMessageAnswerJob(responseWriter http.ResponseWriter, request *http.Request, job *messageAnswerJob) {
	replay, ch, unsubscribe, done := job.subscribe()
	defer unsubscribe()

	for _, chunk := range replay {
		if _, err := responseWriter.Write(chunk); err != nil {
			return
		}
		if flusher, ok := responseWriter.(http.Flusher); ok {
			flusher.Flush()
		}
	}

	if done {
		return
	}

	var notify <-chan struct{}
	if request != nil {
		notify = request.Context().Done()
	}

	for {
		select {
		case chunk, ok := <-ch:
			if !ok {
				return
			}
			if _, err := responseWriter.Write(chunk); err != nil {
				return
			}
			if flusher, ok := responseWriter.(http.Flusher); ok {
				flusher.Flush()
			}
		case <-notify:
			return
		}
	}
}

func generateMessageAnswer(id string, responseWriter http.ResponseWriter, host string, lang string, signedIn bool, responseError func(string, ...interface{})) {
	responseErrorStream := func(message *object.Message, errorText string) {