Method streamReader

src/models/GitPktLine.js:76–93

(stream)

  }

  static streamReader(stream) {
    const reader = new StreamReader(stream)
    return async function read() {
      try {
        let length = await reader.read(4)
        if (length == null) return true
        length = parseInt(length.toString('utf8'), 16)
        if (length === 0) return null
        if (length === 1) return null // delim packets
        const buffer = await reader.read(length - 4)
        if (buffer == null) return true
        return buffer
      } catch (err) {
        stream.error = err
        return true
      }
    }
  }
}