Обработка обещаний потока NDJSON в Stache Can.js - PullRequest
Новая
       39

Обработка обещаний потока NDJSON в Stache Can.js

0 голосов
/ 01 декабря 2018

У меня есть конечная точка API потоковой передачи:

https://step3 -ndjson-stream-api-demo.glitch.me /

Я пытаюсь выполнить рендеринг с помощью can.js поток NDJSON и следующий пример получил некоторый успешный вывод в console.log, но только первый объект.

Вот мой app.js (усеченный): 

const AppViewModel = DefineMap.extend("AppViewModel", {
  // misc. properties, then
  get streamFunct(){
      return fetch(
        'https://step3-ndjson-stream-api-demo.glitch.me/'
      ).then(function(response){
        return ndjsonStream( response.body );
      }).then( ( streamData ) => {

        const reader = streamData.getReader();
        let read;

        reader.read().then( read = ( result ) => {
            if ( result.done ) {
                return;
            }
            console.log( result.value );
            streamData.getReader().read().then( read );
        } );
    } );
  }
});

А вот фрагмент из моего index.stache: 

<p>Stream Data: <strong>{{streamFunct}}</strong></p>

И мое представление разработчика консоли (обратите внимание на успешный первый вызов):

console view

Я думаю, что должен обработать объект обещания в index.stache, но не уверен ... Спасибо за просмотр.

ОБНОВЛЕНИЕ

НаконецЯ могу получить потоковые данные: 

  get streamFunct(){
  return fetch(
    'https://step3-ndjson-stream-api-demo.glitch.me/'
  ).then(function(response){
    return ndjsonStream( response.body );
  }).then( ( streamData ) => {

    //retain access to the reader so that you can cancel it
    const reader = streamData.getReader();
    const listResult = document.querySelector('.displayResult ul')
    let read;

    reader.read().then( read = ( result ) => {
        if ( result.done ) {
            console.log('Failed to find match');
            return;
        }
        const chunk = result.value;
        let listItem = document.createElement('li');
        listItem.textContent = chunk.user;
        listResult.appendChild(listItem);

        return reader.read().then(read);
    } ).catch ((error) => {
      console.log(error);
    });
} );

}

и изменить свой index.stache: 

<p>Stream Data:</p>
<div class="displayResult">
<ul>

</ul>
</div>

Но я все еще получаю ошибки / предупреждения:

UnhandledPromiseRejectionWarning: Ошибка [ERR_HTTP_HEADERS_SENT]: невозможно установить заголовки после их отправки клиенту

[DEP0018] DeprecationWarning: необработанное обещание отклоненоионы устарели.В будущем отклонения обещания, которые не обрабатываются, завершат процесс Node.js с ненулевым кодом завершения.

Неудачное обещание: TypeError: response.getReader не является функцией

Кто-нибудь знает, как их очистить?

...