@graffy/core - npm Package Compare versions

package.json

		@@ -5,3 +5,3 @@ {
		"author": "aravind (https://github.com/aravindet)",
		"version": "0.14.6-beta3",
		"version": "0.14.6-beta4",
		"main": "index.js",
		@@ -17,5 +17,5 @@ "source": "src/index.js",
		"@babel/runtime-corejs3": "^7.9.2",
		"@graffy/common": "0.14.6-beta3",
		"@graffy/stream": "0.14.6-beta3"
		"@graffy/common": "0.14.6-beta4",
		"@graffy/stream": "0.14.6-beta4"
		}
		}

src/Core.js

		@@ -16,3 +16,3 @@ import { unwrap } from '@graffy/common';
		let nextCalled = false;
		return handle(payload, options, nextPayload => {
		return handle(payload, options, (nextPayload) => {
		if (nextCalled) {
		@@ -19,0 +19,0 @@ throw Error('resolve.duplicate_next_call: ' + handlers[i].name);

src/Graffy.js

		@@ -69,3 +69,3 @@ import {
		const subscription = handle(decorateQuery(query), options);
		(async function() {
		(async function () {
		try {
		@@ -101,3 +101,3 @@ let firstValue = (await subscription.next()).value;
		const result = this.core.call(type, payload, options);
		const unwrapResult = value => {
		const unwrapResult = (value) => {
		return value && unwrap(value, this.path);
		@@ -124,3 +124,3 @@ };
		const stream = this.call('watch', query, options \|\| {});
		return mapStream(stream, value => descend(decorate(value), path));
		return mapStream(stream, (value) => descend(decorate(value), path));
		}
		@@ -127,0 +127,0 @@

src/shift.js

		@@ -60,3 +60,3 @@ import { wrap, unwrap, remove, merge, mergeStreams } from '@graffy/common';
		let pushRemaining;
		remainingNextStream = makeStream(push => {
		remainingNextStream = makeStream((push) => {
		pushRemaining = push;
		@@ -77,5 +77,5 @@ });
		const firstValue = await (await unwrappedStream.next()).value;
		const resultStream = makeStream(push => {
		const resultStream = makeStream((push) => {
		push(wrap(firstValue, path));
		mapStream(unwrappedStream, value => {
		mapStream(unwrappedStream, (value) => {
		push(wrap(value, path));
		@@ -82,0 +82,0 @@ });

Improved metrics