Class MemoryReadableStream

tests/test_socket.js:79–98

})

class MemoryReadableStream extends Readable {
  constructor(content) {
    super()
    this._content = content
    this._currentOffset = 0
  }

  _read(size) {
    if (this._currentOffset >= this._content.length) {
      this.push(null)
      return
    }

    const nextOffset = this._currentOffset + size
    const content = this._content.slice(this._currentOffset, nextOffset)
    this._currentOffset = nextOffset

    this.push(content)
  }
}