fix: emit error from internal socket stream (#41)

snow-tree · Nov 12, 2019 · d0e0bd3 · d0e0bd3
1 parent c6a0f3f
commit d0e0bd3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/core/probe.ts b/src/core/probe.ts
@@ -66,7 +66,7 @@ export const probe =
             toArrayOfValues,
             flattenDocumentStrings,
             takeUntil(internalLimit)
-          ).subscribe(msg => obs.next(msg))
+          ).subscribe(msg => obs.next(msg), err => obs.next(err))
 
           return function unsubscribe() {
             internalLimit.next()