Does not write before `insertStream.end()` is called

[gajus]

const insertStream = clickHouse.query('INSERT INTO log_event', {
  format: 'JSONEachRow',
});

insertStream.write({
    message,
});

setTimeout(() => {
  insertStream.end();
}, 1000);

In the above example, nothing will get written until before insertStream.end() is called.

I was expecting that I can just open the query and continue writing for as long as I want, but eventually a timeout error is raised.