Function runTests

test/parallel/test-fastutf8stream-periodicflush.js:27–78

(sync)

runTests(true);

function runTests(sync) {

  {
    const dest = getTempFile();
    const fd = openSync(dest, 'w');
    const stream = new Utf8Stream({ fd, sync, minLength: 5000 });

    assert.ok(stream.write('hello world\n'));

    setTimeout(common.mustCall(() => {
      readFile(dest, 'utf8', common.mustSucceed((data) => {
        assert.strictEqual(data, '');
      }));
    }), 1500);

    stream.destroy();
  }

  {
    const dest = getTempFile();
    const fd = openSync(dest, 'w');

    // Test that periodicFlush property is set correctly
    const stream1 = new Utf8Stream({ fd, sync, minLength: 5000 });
    assert.strictEqual(stream1.periodicFlush, 0);
    stream1.destroy();

    const fd2 = openSync(dest, 'w');
    const stream2 = new Utf8Stream({ fd: fd2, sync, minLength: 5000, periodicFlush: 1000 });
    assert.strictEqual(stream2.periodicFlush, 1000);
    stream2.destroy();
  }

  {
    const dest = getTempFile();
    const fd = openSync(dest, 'w');
    const stream = new Utf8Stream({ fd, sync, minLength: 5000 });

    assert.ok(stream.write('hello world\n'));

    // Manually flush to test that data can be written
    stream.flush(common.mustSucceed());

    setTimeout(common.mustCall(() => {
      readFile(dest, 'utf8', common.mustSucceed((data) => {
        assert.strictEqual(data, 'hello world\n');
      }));
    }), 500);

    stream.destroy();
  }
}