@graphy/content.nq.read
Advanced tools
Comparing version 4.1.0 to 4.2.0
35
main.js
// queueMicrotask shim | ||
{ | ||
// not defined or not a function | ||
if('function' !== typeof queueMicrotask) { | ||
// create resolved promise | ||
let dp_resolve = Promise.resolve(); | ||
// try to redefine | ||
try { | ||
// eslint-disable-next-line no-global-assign | ||
queueMicrotask = fk => dp_resolve.then(fk) | ||
.catch(e_callback => setTimeout(() => { | ||
throw e_callback; | ||
}, 0)); | ||
} | ||
// oh well, at least we tried | ||
catch(e_define) {} | ||
} | ||
} | ||
const stream = require('@graphy/core.iso.stream'); | ||
@@ -478,5 +500,5 @@ const factory = require('@graphy/core.data.factory'); | ||
// go async so caller has chance to bind event listeners | ||
setTimeout(() => { | ||
queueMicrotask(() => { | ||
ds_input.pipe(ds_transform); | ||
}, 0); | ||
}); | ||
} | ||
@@ -488,5 +510,5 @@ // string | ||
// go async so caller has chance to bind event listeners | ||
setTimeout(() => { | ||
queueMicrotask(() => { | ||
ds_transform.end(s_input, 'utf8'); | ||
}, 0); | ||
}); | ||
} | ||
@@ -1267,2 +1289,7 @@ // invalid arg | ||
// input given unspecified | ||
if(z_arg_0 && z_arg_0.input && 'undefined' === typeof z_arg_0.input.string && !z_arg_0.input.stream) { | ||
z_arg_0 = z_arg_0.input; | ||
} | ||
// string | ||
@@ -1269,0 +1296,0 @@ if('string' === typeof z_arg_0) { |
{ | ||
"name": "@graphy/content.nq.read", | ||
"version": "4.1.0", | ||
"version": "4.2.0", | ||
"description": "Single-threaded RDF N-Quads content reader", | ||
@@ -26,4 +26,4 @@ "keywords": [ | ||
"dependencies": { | ||
"@graphy/core.data.factory": "^4.1.0", | ||
"@graphy/core.iso.stream": "^4.1.0" | ||
"@graphy/core.data.factory": "^4.2.0", | ||
"@graphy/core.iso.stream": "^4.2.0" | ||
}, | ||
@@ -30,0 +30,0 @@ "engines": { |
36508
1116