Method set

test/processor.tests.js:34–43

(data, limit, offset)

  // Mock output transport with set method
  async set (data, limit, offset) {
    if (this.options.simulateWriteError) {
      if (typeof this.options.simulateWriteError === 'number') {
        this.options.simulateWriteError--
      }
      throw new Error('Simulated write error')
    }
    this.outputData.push(...data)
    return data.length
  }
}

describe('TransportProcessor', () => {