@graffy/core - npm Package Compare versions

Comparing version 0.14.2-alpha3 to 0.14.2

Graffy.js

		@@ -8,4 +8,2 @@ "use strict";

		var _map = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/map"));

		var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
		@@ -23,3 +21,3 @@

		var _stream = _interopRequireDefault(require("@graffy/stream"));
		var _stream = require("@graffy/stream");

		@@ -139,3 +137,3 @@ var _shift = require("./shift.js");
		this.on('watch', path, function porcelainWatch(query, options) {
		return (0, _stream["default"])(function (push) {
		return (0, _stream.makeStream)(function (push) {
		var subscription = handle((0, _common.decorateQuery)(query), options);
		@@ -343,3 +341,3 @@ (0, _asyncToGenerator2["default"])(
		var stream = this.call('watch', query, options \|\| {});
		return (0, _map["default"])(stream).call(stream, function (value) {
		return (0, _stream.mapStream)(stream, function (value) {
		return (0, _common.descend)((0, _common.decorate)(value), path);
		@@ -346,0 +344,0 @@ });

package.json

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

shift.js

		@@ -23,3 +23,3 @@ "use strict";

		var _stream = _interopRequireDefault(require("@graffy/stream"));
		var _stream = require("@graffy/stream");

		@@ -248,3 +248,3 @@ function mapStream(_x5, _x6) {
		if (remainingPayload.length) (0, _common.merge)(nextPayload, remainingPayload);
		remainingNextStream = (0, _stream["default"])(function (push) {
		remainingNextStream = (0, _stream.makeStream)(function (push) {
		pushRemaining = push;
		@@ -357,3 +357,3 @@ });
		firstValue = _context4.sent;
		resultStream = (0, _stream["default"])(function (push) {
		resultStream = (0, _stream.makeStream)(function (push) {
		push((0, _common.wrap)(firstValue, path));
		@@ -360,0 +360,0 @@ mapStream(unwrappedStream, function (value) {

src/Graffy.js

		@@ -12,3 +12,3 @@ import {
		} from '@graffy/common';
		import makeStream from '@graffy/stream';
		import { makeStream, mapStream } from '@graffy/stream';
		import { shiftFn, shiftGen } from './shift.js';
		@@ -111,3 +111,3 @@ import Core from './Core';
		const stream = this.call('watch', query, options \|\| {});
		return stream.map(value => descend(decorate(value), path));
		return mapStream(stream, value => descend(decorate(value), path));
		}
		@@ -114,0 +114,0 @@

src/shift.js

		import { wrap, unwrap, remove, merge, mergeStreams } from '@graffy/common';
		import makeStream from '@graffy/stream';
		import { makeStream } from '@graffy/stream';

		@@ -4,0 +4,0 @@ async function mapStream(stream, fn) {

New alerts