code: function WritableStream(table, options, connection) {
    this._table = table;
    this._options = options;
    this._cache = [];
    this._pendingCallback = null;
    this._inserting = false;
    this._delayed = false;
    this._connection = connection;
    this._highWaterMark = options.highWaterMark || 100;
  
    this._insertOptions = {};
    this._insertOptions.durability = options.durability || 'hard';
    this._insertOptions.conflict = options.conflict || 'error';
  
    // Internal option to run some tests
    if (options.debug === true) {
      this._sequence = [];
    }
  
    Writable.call(this, {
      objectMode: true,
      highWaterMark: this._highWaterMark
    });
    this._i = 0;
  }
docs: Experimental, but should work fine.