@graffy/core
Advanced tools
Comparing version
@@ -106,12 +106,14 @@ "use strict"; | ||
case 0: | ||
_context3.t0 = _common.makeFinalGraph; | ||
_context3.next = 3; | ||
_context3.t0 = _common.finalize; | ||
_context3.t1 = _common.makeGraph; | ||
_context3.next = 4; | ||
return handle((0, _common.decorateQuery)(query), options); | ||
case 3: | ||
_context3.t1 = _context3.sent; | ||
_context3.t2 = query; | ||
return _context3.abrupt("return", (0, _context3.t0)(_context3.t1, _context3.t2)); | ||
case 4: | ||
_context3.t2 = _context3.sent; | ||
_context3.t3 = (0, _context3.t1)(_context3.t2); | ||
_context3.t4 = query; | ||
return _context3.abrupt("return", (0, _context3.t0)(_context3.t3, _context3.t4)); | ||
case 6: | ||
case 8: | ||
case "end": | ||
@@ -154,3 +156,3 @@ return _context3.stop(); | ||
firstValue = _context4.sent.value; | ||
push(firstValue && (0, _common.makeFinalGraph)(firstValue, query)); | ||
push(firstValue && (0, _common.finalize)((0, _common.makeGraph)(firstValue), query)); | ||
_iteratorNormalCompletion = true; | ||
@@ -157,0 +159,0 @@ _didIteratorError = false; |
@@ -5,3 +5,3 @@ { | ||
"author": "aravind (https://github.com/aravindet)", | ||
"version": "0.13.10", | ||
"version": "0.13.11", | ||
"main": "index.js", | ||
@@ -17,5 +17,5 @@ "source": "src/index.js", | ||
"@babel/runtime-corejs3": "^7.8.3", | ||
"@graffy/common": "0.13.10", | ||
"@graffy/stream": "0.13.10" | ||
"@graffy/common": "0.13.11", | ||
"@graffy/stream": "0.13.11" | ||
} | ||
} |
@@ -8,3 +8,3 @@ import { | ||
makeQuery, | ||
makeFinalGraph, | ||
finalize, | ||
unwrap, | ||
@@ -58,3 +58,6 @@ wrap, | ||
this.on('read', path, async function porcelainRead(query, options) { | ||
return makeFinalGraph(await handle(decorateQuery(query), options), query); | ||
return finalize( | ||
makeGraph(await handle(decorateQuery(query), options)), | ||
query, | ||
); | ||
}); | ||
@@ -70,3 +73,3 @@ } | ||
let firstValue = (await subscription.next()).value; | ||
push(firstValue && makeFinalGraph(firstValue, query)); | ||
push(firstValue && finalize(makeGraph(firstValue), query)); | ||
for await (const value of subscription) { | ||
@@ -73,0 +76,0 @@ push(value && makeGraph(value)); |
39627
0.39%957
0.53%+ Added
+ Added
- Removed
- Removed
Updated
Updated