@@ -112,7 +112,7 @@ describe('withEgressTracker', async () => {
112112 const largeContent = new Uint8Array ( 100 * 1024 * 1024 ) // 100 MB
113113 const totalBytes = largeContent . byteLength
114114 const mockResponse = new Response ( new ReadableStream ( {
115- start ( controller ) {
115+ start ( controller ) {
116116 controller . enqueue ( largeContent )
117117 controller . close ( )
118118 }
@@ -138,7 +138,7 @@ describe('withEgressTracker', async () => {
138138 const totalBytes = Buffer . byteLength ( chunk1 ) + Buffer . byteLength ( chunk2 )
139139
140140 const mockResponse = new Response ( new ReadableStream ( {
141- start ( controller ) {
141+ start ( controller ) {
142142 controller . enqueue ( chunk1 )
143143 controller . enqueue ( chunk2 )
144144 controller . close ( )
@@ -175,7 +175,7 @@ describe('withEgressTracker', async () => {
175175
176176 // Mock a response with the CAR file content
177177 const mockResponse = new Response ( new ReadableStream ( {
178- start ( controller ) {
178+ start ( controller ) {
179179 controller . enqueue ( carBytes )
180180 controller . close ( )
181181 }
@@ -214,7 +214,7 @@ describe('withEgressTracker', async () => {
214214 const totalBytes = Buffer . byteLength ( content )
215215
216216 const mockResponse = new Response ( new ReadableStream ( {
217- start ( controller ) {
217+ start ( controller ) {
218218 setTimeout ( ( ) => {
219219 controller . enqueue ( content )
220220 controller . close ( )
@@ -286,14 +286,14 @@ describe('withEgressTracker', async () => {
286286 const totalBytes2 = Buffer . byteLength ( content2 )
287287
288288 const mockResponse1 = new Response ( new ReadableStream ( {
289- start ( controller ) {
289+ start ( controller ) {
290290 controller . enqueue ( content1 )
291291 controller . close ( )
292292 }
293293 } ) , { status : 200 } )
294294
295295 const mockResponse2 = new Response ( new ReadableStream ( {
296- start ( controller ) {
296+ start ( controller ) {
297297 controller . enqueue ( content2 )
298298 controller . close ( )
299299 }
@@ -335,7 +335,7 @@ describe('withEgressTracker', async () => {
335335 describe ( '-> Zero-byte Responses' , ( ) => {
336336 it ( 'should not record egress for zero-byte responses' , async ( ) => {
337337 const mockResponse = new Response ( new ReadableStream ( {
338- start ( controller ) {
338+ start ( controller ) {
339339 // Do not enqueue any data, simulating a zero-byte response
340340 controller . close ( )
341341 }
@@ -357,7 +357,7 @@ describe('withEgressTracker', async () => {
357357 describe ( '-> Interrupted Connection' , ( ) => {
358358 it ( 'should not record egress if there is a stream error while downloading' , async ( ) => {
359359 const mockResponse = new Response ( new ReadableStream ( {
360- start ( controller ) {
360+ start ( controller ) {
361361 controller . error ( new Error ( 'Stream error' ) )
362362 }
363363 } ) , { status : 200 } )
@@ -381,7 +381,7 @@ describe('withEgressTracker', async () => {
381381 it ( 'should not record egress if the connection is interrupted during a large file download' , async ( ) => {
382382 const largeContent = new Uint8Array ( 100 * 1024 * 1024 ) // 100 MB
383383 const mockResponse = new Response ( new ReadableStream ( {
384- start ( controller ) {
384+ start ( controller ) {
385385 // Stream a portion of the content
386386 controller . enqueue ( largeContent . subarray ( 0 , 10 * 1024 * 1024 ) ) // 10 MB
387387 // Simulate connection interruption by raising an error
@@ -410,7 +410,7 @@ describe('withEgressTracker', async () => {
410410 it ( 'should log an error and continue serving the response if the ucanto client fails' , async ( ) => {
411411 const content = new TextEncoder ( ) . encode ( 'Hello, world!' )
412412 const mockResponse = new Response ( new ReadableStream ( {
413- start ( controller ) {
413+ start ( controller ) {
414414 controller . enqueue ( content )
415415 controller . close ( )
416416 }
0 commit comments