[Bug] Circular Buffer Implementation Error in Stream Processing

Resolved 💬 3 comments Opened Sep 4, 2025 by jlmacedo Closed Sep 8, 2025

Bug Description
(ir2(),1);class WZ1{capacity;buffer;head=0;size=0;constructor(A){this.capacity=A;this.buffer=new Array(A)}add(A){if(this.buffer[this.head]=A,this.head=(this.head+1)%this.capacity,this.size<this.capacity)this.size++}addAll(A){for(let B of A)this.add(B)}getRecent(A){let B=[],Q=this.size<this.ca
pacity?0:this.head,Z=Math.min(A,this.size);for(let G=0;G<Z;G++){let Y=(Q+this.size-Z+G)%this.capacity;B.push(this.buffer[Y])}return B}toArray(){if(this.size===0)return[];let A=[],B=this.size<this.capacity?0:this.head;for(let Q=0;Q<this.size;Q++){let Z=(B+Q)%this.capacity;A.push(this.buffer[Z])}return A}c
lear(){this.head=0,this.size=0}length(){return this.size}}var nr2=137,ar2=143;function sr2(A){let B=null,Q="";A.on("data",(G)=>{if(B)B.write(G);else Q+=G});let Z=()=>Q;return{get:Z,asStream(){return B=new jN6({highWaterMark:10485760}),B.write(Z()),Q="",B}}}function or2(A,B,Q,Z){let G="running",Y,I=sr2(A.stdout),W=sr2(A.stderr);if(Z){let K=new WZ1(10),H=0,z=(D)=>{let w=D.toString().split(`
e-code/cli.js:1452:1678)
at Socket.emit (node:events:530:35)
at Socket.emit (node:domain:489:12)
at addChunk (node:internal/streams/readable:561:12)
at readableAddChunkPushByteMode (node:internal/streams/readable:512:3)
at Readable.push (node:internal/streams/readable:392:5)
at Pipe.onStreamRead (node:internal/stream_base_commons:189:23)

Environment Info

  • Platform: win32
  • Terminal: pycharm
  • Version: 1.0.105
  • Feedback ID: 9afbeb08-c728-4b3c-a598-171f9a6a765c

Errors

[]

View original on GitHub ↗

This issue has 3 comments on GitHub. Read the full discussion on GitHub ↗