@graffy/testing
Advanced tools
Comparing version 0.14.6-alpha6 to 0.14.6-alpha7
@@ -31,2 +31,3 @@ "use strict"; | ||
watch: function watch() { | ||
// console.log('onWatch received'); | ||
return (0, _stream.makeStream)(function (push, _end) { | ||
@@ -41,3 +42,4 @@ listeners.add(push); | ||
write: function write(change) { | ||
(0, _common.merge)(state, change); | ||
// change = setVersion(change, Date.now()); | ||
(0, _common.merge)(state, change); // console.log('Emitting change', listeners.size, debug(change)); | ||
@@ -44,0 +46,0 @@ for (var _iterator = listeners, _isArray = (0, _isArray2["default"])(_iterator), _i = 0, _iterator = _isArray ? _iterator : (0, _getIterator2["default"])(_iterator);;) { |
@@ -5,3 +5,3 @@ { | ||
"author": "aravind (https://github.com/aravindet)", | ||
"version": "0.14.6-alpha6", | ||
"version": "0.14.6-alpha7", | ||
"main": "index.js", | ||
@@ -17,5 +17,5 @@ "source": "src/index.js", | ||
"@babel/runtime-corejs3": "^7.8.4", | ||
"@graffy/common": "0.14.6-alpha6", | ||
"@graffy/stream": "0.14.6-alpha6" | ||
"@graffy/common": "0.14.6-alpha7", | ||
"@graffy/stream": "0.14.6-alpha7" | ||
} | ||
} |
@@ -11,10 +11,14 @@ import { merge } from '@graffy/common'; | ||
read: () => state, | ||
watch: () => | ||
makeStream((push, _end) => { | ||
watch: () => { | ||
// console.log('onWatch received'); | ||
return makeStream((push, _end) => { | ||
listeners.add(push); | ||
push(options.liveQuery ? state : undefined); | ||
return () => listeners.delete(push); | ||
}), | ||
}); | ||
}, | ||
write: change => { | ||
// change = setVersion(change, Date.now()); | ||
merge(state, change); | ||
// console.log('Emitting change', listeners.size, debug(change)); | ||
for (const push of listeners) push(change); | ||
@@ -21,0 +25,0 @@ return change; |
7532
177
+ Added@graffy/common@0.14.6-alpha7(transitive)
+ Added@graffy/stream@0.14.6-alpha7(transitive)
- Removed@graffy/common@0.14.6-alpha6(transitive)
- Removed@graffy/stream@0.14.6-alpha6(transitive)
Updated@graffy/common@0.14.6-alpha7
Updated@graffy/stream@0.14.6-alpha7