Fix blocked pipeline on error.

timoxley · timoxley · commit 9245a52eb3bd · 2021-03-19T12:48:26.000-04:00
diff --git a/src/subscribe/index.ts b/src/subscribe/index.ts
@@ -469,7 +469,6 @@ class Subscriptions {
             }
         } finally {
             await cancelTask // only wait for cancel at end
-            await sub.onDone()
         }
     }
 
diff --git a/src/subscribe/pipeline.js b/src/subscribe/pipeline.js
@@ -78,7 +78,6 @@ export default function MessagePipeline(client, opts = {}, onFinally = async ()
         async function* ValidateMessages(src) {
             try {
                 for await (const streamMessage of src) {
-                    client.debug('loop')
                     try {
                         await validate(streamMessage)
                     } catch (err) {

Original file line number	Diff line number	Diff line change
`@@ -469,7 +469,6 @@ class Subscriptions {`
`469`	`469`	`}`
`470`	`470`	`} finally {`
`471`	`471`	`await cancelTask // only wait for cancel at end`
`472`		`- await sub.onDone()`
`473`	`472`	`}`
`474`	`473`	`}`
`475`	`474`