Как создать тело ответа с асинхронно созданными кусками тела в Swift Vapor

Question

Я изучаю структуру Swift Vapor.

Я пытаюсь создать класс контроллера, который отображает данные, полученные по ссылке SSL, на стороннюю систему (сервер Asterisk PBX) в тело ответа, которое отправляется через некоторое время до клиента.

Так что мне нужно отправить полученные текстовые строки (полученные отдельно по SSL-соединению) по мере их поступления, не дожидаясь завершения «полного ответа».

Видя этот пример:

return Response(status: .ok) { chunker in 
    for name in ["joe\n", "pam\n", "cheryl\n"] { 
     sleep(1) 
     try chunker.send(name) 
    } 

    try chunker.close() 
} 

Я думал, что это может быть путь.

Но я вижу, что соединение с сервером Vapor заключается в том, что вызов REST ожидает завершения цикла, прежде чем три строки будут получены в результате.

Как я могу получить, чтобы попробовать chunker.send (имя) отправить свои символы обратно клиенту, не дождавшись завершения цикла?

В реальном коде метод контроллера потенциально может поддерживать HTTP-соединение с клиентом открытым в течение длительного времени, отправляя данные активности Asterisk клиенту, как только он будет получен. Поэтому каждый .send (name) должен фактически передавать данные клиенту, не дожидаясь окончательного вызова .close().

Добавление попробовать chunker.flush() не производит никакого лучшего результата ..

Answer 1

HTTP запросы на самом деле не предназначены для работы, как это. Различные браузеры и клиенты будут работать по-разному в зависимости от их реализации.

Например, если вы подключаетесь с telnet к приведенному вами примеру chunker, вы увидите, что данные отправляются каждую секунду. Но Safari, с другой стороны, будет ожидать весь ответ перед отображением.

Если вы хотите отправить данные, подобные этому надежно, вы должны использовать протокол, подобный WebSockets, который предназначен для него.