@@ -257,7 +257,7 @@ async function createUploadRequest(
257257 await events . once ( req , 'drain' )
258258 }
259259 } else if ( typeof part ?. pipe === 'function' ) {
260- // Stream data chunk-by-chunk with backpressure support
260+ // Stream data chunk-by-chunk with backpressure support.
261261 const stream = part as Readable
262262 // eslint-disable-next-line no-await-in-loop
263263 for await ( const chunk of stream ) {
@@ -273,7 +273,7 @@ async function createUploadRequest(
273273 // eslint-disable-next-line no-await-in-loop
274274 await events . once ( req , 'drain' )
275275 }
276- // Cleanup stream to free memory buffers/
276+ // Cleanup stream to free memory buffers.
277277 if ( typeof part . destroy === 'function' ) {
278278 part . destroy ( )
279279 }
@@ -410,9 +410,7 @@ function promiseWithResolvers<T>(): ReturnType<
410410 return Promise . withResolvers < T > ( )
411411 }
412412
413- // This is what the above does but it's not available in node 20 (it is in node 22)
414- // @ts -ignore -- sigh.
415- const obj : ReturnType < typeof Promise . withResolvers < T > > = { }
413+ const obj = { } as ReturnType < typeof Promise . withResolvers < T > >
416414 obj . promise = new Promise < T > ( ( resolver , reject ) => {
417415 obj . resolve = resolver
418416 obj . reject = reject
@@ -735,7 +733,7 @@ export class SocketSdk {
735733 running . findIndex ( entry => entry . generator === generator ) ,
736734 1
737735 )
738- // Yield the value if one is given, even when done:true
736+ // Yield the value if one is given, even when done:true.
739737 if ( iteratorResult . value ) {
740738 yield iteratorResult . value
741739 }
0 commit comments