Response readable stream?

Question

[Богдан]

Здравствуйте. А не подскажите, как есть через response вернуть json readable stream в котором chunk object?

const http = require('http');
const { Readable } = require('stream');

http.createServer((request, response) => {
  const data = [{ a: 1 }, { b: 2 }, { c: 3 }, { d: 4 }, { e: 5 }];
  const readable = Readable.from(data, { objectMode: true });
  readable.pipe(response);
}).listen(8080);

events.js:187
      throw er; // Unhandled 'error' event
      ^

TypeError [ERR_INVALID_ARG_TYPE]: The first argument must be one of type string or Buffer. Received type object
    at write_ (_http_outgoing.js:618:11)
    at ServerResponse.write (_http_outgoing.js:586:15)
    at Readable.ondata (_stream_readable.js:726:22)
    at Readable.emit (events.js:210:5)
    at addChunk (_stream_readable.js:308:12)
    at readableAddChunk (_stream_readable.js:289:11)
    at Readable.push (_stream_readable.js:223:10)
    at next (_stream_readable.js:1223:27)
    at processTicksAndRejections (internal/process/task_queues.js:93:5)
Emitted 'error' event on Readable instance at:
    at emitErrorNT (internal/streams/destroy.js:92:8)
    at emitErrorAndCloseNT (internal/streams/destroy.js:60:3)
    at processTicksAndRejections (internal/process/task_queues.js:80:21) {
  code: 'ERR_INVALID_ARG_TYPE'
}

Спасибо.

Answer 1

[Владимир Скибин]

Попробуйте так

const readable = Readable.from(Buffer.from(data), { objectMode: true });

Comments

[Богдан]

Спасибо, тут проблема не в readable stream, а именно в response
Вот так вроде как бы работает, но тут не json возвращает

const http = require('http');
const stream = require('stream');

class ToJSON extends stream.Transform {
  writableObjectMode = true;

  _transform(chunk, encoding, done) {
    this.push(JSON.stringify(chunk)  + ',');
    done();
  }
}

http.createServer((request, response) => {
  response.writeHead(200, {
    'Content-Type': 'application/json',
    'Transfer-Encoding': 'chunked'
  })

  const data = [{ a: 1 }, { b: 2 }, { c: 3 }, { d: 4 }, { e: 5 }];
  const readable = stream.Readable.from(data, { objectMode: true });
  readable
    .pipe(new ToJSON({ objectMode: true }))
    .pipe(response);
}).listen(8080);

/*
{
    "a": 1
},
{
    "b": 2
},
{
    "c": 3
},
{
    "d": 4
},
{
    "e": 5
},
*/

[Владимир Скибин]

Богдан, у Вас в потоке должен гоняться "потоковый" тип данных, о чем Вам указала предыдущая ошибка

The first argument must be one of type string or Buffer. Received type object

по этому чтобы именно Object проходил - то никак. Ловите на той стороне буфер или стринг и его уже обрабатывайте

[Богдан]

Владимир Скибин, Логически я это понимаю, но все-таки как на той стороне этот буфер преобразить в объект

[Владимир Скибин]

Богдан, На той, это на какой? На выводе браузера? Так там строка. Если Вы делаете что то типа АПИ - то тогда ловите строку, парсите его JSON (предварительно обработав ошибки) и уже работает с объектом.