@transformation/core
Advanced tools
Comparing version 4.1.0 to 4.1.1
{ | ||
"name": "@transformation/core", | ||
"version": "4.1.0", | ||
"version": "4.1.1", | ||
"description": "Create transformation pipelines", | ||
@@ -32,3 +32,3 @@ "main": "./src/index.js", | ||
}, | ||
"gitHead": "515bd8a714852520556f12b42640257e0463eecf" | ||
"gitHead": "38cac774e2c1a352cdfbf6fd30d4c7effb319025" | ||
} |
@@ -29,8 +29,5 @@ const { go, chan, close, CLOSED, take, sleep } = require("medium"); | ||
try { | ||
const error = await Promise.race([take(errors), sleep(0)]); | ||
if (error) throw error; | ||
} finally { | ||
close(errors); | ||
} | ||
await sleep(0); | ||
close(errors); | ||
close(output); | ||
@@ -37,0 +34,0 @@ if (error) throw error; |
143080
3540