Как отправить поток объекта json клиенту?

Question

Это может быть повторяющийся вопрос, но не может найти никакого решения там. Я уже пытался найти его в эти быстрые часы, но мне не повезло.

Мой вопрос заключается в том, как я могу отправить поток (IDK, если поток является правильным термином) объектов JSON клиенту.

Пример Я читаю данные в БД, и на каждых 5 найденных записях я отправляю данные клиенту в формате json. Затем прочитайте данные на клиенте, используя Angular httpclient lib.

Я уже пробовал expressjs response.write(), но клиент не смог получить данные, пока я не позвоню response.end(),

Как правильно это сделать?

Я думал о socket.io, но это было бы излишним.

редактировать

Другой пример

function getData(res: Response, req: Request):void {
  for(let i = 0; i<100; i++{
    res.write(JSON.stringify({data:1}) + '\n');
  }

  res.end(); // There is data received on the browser until this was called.
}

Или как то так. Я ожидал, что данные будут поступать каждую секунду, но они появлялись в одно и то же время после 10 секунд.

function getData(res, req){
  const s = setInterval(()=>{
    res.write(JSON.stringify({value: 'test value'}));
  }, 1000);

  setTimeout(()=>{
    clearInterval(s);
    res.end();
  }, 10000);
}

Answer 1

Итак, я обнаружил, что приведенный выше пример кода не имеет проблем, а также правильный способ сделать это.

Когда я попытался открыть URL-адрес API непосредственно в браузере, я увидел, что браузер получает данные.

Проблема связана с угловой библиотекой httpclient, которую я использую для извлечения данных. Она покажет данные, если все уже загружено.

Но, к счастью, я нашел этот пакет oboe.js, он может делать то, что я хочу для потоковой передачи данных json. Поэтому, когда экспресс JS отправит данные через res.write() Гобой сможет получить данные и готов к употреблению.

Вы можете сделать это так просто.

oboe('your url').node('!', data=>{
  // process your data here.
  // the '!' selector means that oboe will just show the data if it is a valid json.
});