fix(stream): fixed streams added example

fix #37

README.md

@@ -542,6 +542,8 @@ new Listr<Ctx>(
 
 Since observables and streams are supported they can also be used to generate output.
 
+_Please refer to [examples section](examples/stream.example.ts) for more detailed and further examples._
+
 ```typescript
 new Listr<Ctx>(
   [

examples/stream.example.ts

@@ -0,0 +1,42 @@
+/* eslint-disable @typescript-eslint/no-empty-function */
+
+import { spawn } from 'child_process'
+import { Readable } from 'stream'
+
+import { Listr } from '@root/index'
+import { Logger } from '@utils/logger'
+
+interface Ctx {
+  output: string
+}
+
+const logger = new Logger({ useIcons: false })
+
+async function main (): Promise<void> {
+  let task: Listr<Ctx>
+
+  logger.start('Example output from a task.')
+
+  // eslint-disable-next-line prefer-const
+  task = new Listr<Ctx>([
+    {
+      title: 'This task will execute.',
+      task: async (): Promise<Readable> => {
+        return spawn('ls').stdout
+      },
+      options: {
+        persistentOutput: true
+      }
+    }
+  ], { concurrent: false })
+
+  try {
+    const context = await task.run()
+    logger.success(`Context: ${JSON.stringify(context)}`)
+  } catch(e) {
+    logger.fail(e)
+  }
+
+}
+
+main()

package.json

@@ -53,7 +53,6 @@
     "idle"
   ],
   "dependencies": {
-    "@samverschueren/stream-to-observable": "^0.3.0",
     "chalk": "^4.0.0",
     "cli-cursor": "^3.1.0",
     "cli-truncate": "^2.1.0",
@@ -95,4 +94,4 @@
       "path": "./node_modules/cz-conventional-changelog"
     }
   }
-}
+}

src/lib/task-wrapper.ts

@@ -86,6 +86,8 @@ export class TaskWrapper<Ctx, Renderer extends ListrRendererFactory> implements
     return through((chunk: string) => {
       const pattern = new RegExp('(?:\\u001b|\\u009b)\\[[\\=><~/#&.:=?%@~_-]*[0-9]*[\\a-ln-tqyz=><~/#&.:=?%@~_-]+', 'gmi')
 
+      chunk = chunk.toString()
+
       chunk = chunk.replace(pattern, '')
       chunk = chunk.replace(new RegExp(/\u0007/, 'gmi'), '')
       if (chunk !== '') {

src/lib/task.ts

@@ -1,6 +1,5 @@
-import sttoob from '@samverschueren/stream-to-observable'
 import { Observable, Subject } from 'rxjs'
-import { Stream } from 'stream'
+import { Readable } from 'stream'
 import { v4 as uuid } from 'uuid'
 
 import {
@@ -143,9 +142,20 @@ export class Task<Ctx, Renderer extends ListrRendererFactory> extends Subject<Li
       } else if (result instanceof Promise) {
         // Detect promise
         result = result.then(handleResult)
-      } else if (result instanceof Stream.Readable) {
+      } else if (result instanceof Readable) {
         // Detect stream
-        result = sttoob(result)
+        result = new Promise((resolve, reject) => {
+          result.on('data', (data: Buffer) => {
+            this.output = data.toString()
+
+            this.next({
+              type: 'DATA',
+              data: data.toString()
+            })
+          })
+          result.on('error', (error: Error) => reject(error))
+          result.on('end', () => resolve())
+        })
       } else if (result instanceof Observable) {
         // Detect Observable
         result = new Promise((resolve, reject) => {