export ProgressStream class

example/progress.ts

@@ -1,5 +1,5 @@
 import http from 'node:http'
-import progressStream from '../src/progress'
+import progressStream from 'dunai/progress'
 
 const str = progressStream({
   drain: true,

package.json

@@ -6,7 +6,8 @@
     "@types/node": "^22.10.10",
     "expect": "^29.7.0",
     "tsx": "^4.19.2",
-    "typescript": "^5.7.3"
+    "typescript": "^5.7.3",
+    "dunai": "link:./"
   },
   "exports": {
     "./concat": {

src/progress.ts

@@ -58,7 +58,7 @@ export interface ProgressUpdate {
 
 type ProgressCallback = (update: ProgressUpdate) => void
 
-interface ProgressStream extends Transform {
+export interface ProgressStream extends Transform {
   on(event: string | symbol, listener: (...args: any[]) => void): this
   on(event: 'length', listener: (length: number) => void): this
   on(event: 'progress', listener: (update: ProgressUpdate) => void): this
@@ -67,7 +67,7 @@ interface ProgressStream extends Transform {
   emit(event: 'progress', update: ProgressUpdate): boolean
 }
 
-class ProgressStream extends Transform {
+export class ProgressStream extends Transform {
   #length: number
   #time: number
   #drain: boolean
@@ -183,6 +183,6 @@ class ProgressStream extends Transform {
   }
 }
 
-export default function progressStream(options?: ProgressOptions | ProgressCallback, onprogress?: ProgressCallback) {
+export function createProgressStream(options?: ProgressOptions | ProgressCallback, onprogress?: ProgressCallback) {
   return new ProgressStream(options, onprogress)
 }

test/progress.test.ts

@@ -2,7 +2,7 @@ import assert from 'node:assert/strict'
 import { Readable, Transform } from 'node:stream'
 import { pipeline } from 'node:stream/promises'
 import { beforeEach, describe, it, mock } from 'node:test'
-import progressStream from '../src/progress'
+import { createProgressStream } from '../src/progress'
 import type { ProgressUpdate } from '../src/progress'
 
 const sampleData = Buffer.alloc(1024 * 10)
@@ -22,7 +22,7 @@ describe('ProgressStream', () => {
   })
 
   async function runTestStream(options: any = {}, data = sampleData) {
-    const stream = progressStream({
+    const stream = createProgressStream({
       time: 10,
       drain: true,
       ...options
@@ -66,7 +66,7 @@ describe('ProgressStream', () => {
   })
 
   it('should handle dynamic length updates via setLength', async () => {
-    const stream = progressStream({ time: 10, drain: true })
+    const stream = createProgressStream({ time: 10, drain: true })
     const onProgress = mock.fn((update: ProgressUpdate) => {
       lastUpdate = update
     })