1

hao

2025-03-27 e610e1c17f62b423a717fadaaa7b139d02857793

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
"use strict";
 
let SyncReader = (module.exports = function (buffer) {
  this._buffer = buffer;
  this._reads = [];
});
 
SyncReader.prototype.read = function (length, callback) {
  this._reads.push({
    length: Math.abs(length), // if length < 0 then at most this length
    allowLess: length < 0,
    func: callback,
  });
};
 
SyncReader.prototype.process = function () {
  // as long as there is any data and read requests
  while (this._reads.length > 0 && this._buffer.length) {
    let read = this._reads[0];
 
    if (
      this._buffer.length &&
      (this._buffer.length >= read.length || read.allowLess)
    ) {
      // ok there is any data so that we can satisfy this request
      this._reads.shift(); // == read
 
      let buf = this._buffer;
 
      this._buffer = buf.slice(read.length);
 
      read.func.call(this, buf.slice(0, read.length));
    } else {
      break;
    }
  }
 
  if (this._reads.length > 0) {
    return new Error("There are some read requests waitng on finished stream");
  }
 
  if (this._buffer.length > 0) {
    return new Error("unrecognised content at end of stream");
  }
};