test: add delayed pipe() test

google · Oct 2, 2024 · 4159751 · 4159751
1 parent 4cdef35
commit 4159751
Showing 1 changed file with 15 additions and 1 deletion.
diff --git a/test/core.test.js b/test/core.test.js
@@ -305,7 +305,7 @@ describe('core', () => {
       assert.equal(p.cmd, "echo $'#bar' --t 1")
     })
 
-    test.only('stdio() works', async () => {
+    test('stdio() works', async () => {
       let p = $`printf foo`
       await p
       // assert.throws(() => p.stdin)
@@ -384,6 +384,20 @@ describe('core', () => {
         assert.equal(stdout, 'HELLO WORLD\n')
       })
 
+      it('supports multipiping', async () => {
+        const result = $`echo 1; sleep 1; echo 2; sleep 1; echo 3`
+        const piped1 = result.pipe`cat`
+        let piped2
+
+        setTimeout(() => {
+          piped2 = result.pipe`cat`
+        }, 1500)
+
+        await piped1
+        assert.equal((await piped1).toString(), '1\n2\n3\n')
+        assert.equal((await piped2).toString(), '1\n2\n3\n')
+      })
+
       test.skip('throws if already resolved', async (t) => {
         let ok = true
         let p = $`echo "Hello"`