frint-component-utils
Advanced tools
Comparing version 3.3.1 to 4.0.0
(function webpackUniversalModuleDefinition(root, factory) { | ||
if(typeof exports === 'object' && typeof module === 'object') | ||
module.exports = factory(require("lodash/isPlainObject"), require("rxjs/observable/of"), require("rxjs/observable/merge"), require("rxjs/operator/concatMap"), require("rxjs/operator/scan")); | ||
module.exports = factory(require("lodash/isPlainObject"), require("rxjs/observable/of"), require("rxjs/observable/merge"), require("rxjs/operators/concatMap"), require("rxjs/operators/scan")); | ||
else if(typeof define === 'function' && define.amd) | ||
define(["lodash/isPlainObject", "rxjs/observable/of", "rxjs/observable/merge", "rxjs/operator/concatMap", "rxjs/operator/scan"], factory); | ||
define(["lodash/isPlainObject", "rxjs/observable/of", "rxjs/observable/merge", "rxjs/operators/concatMap", "rxjs/operators/scan"], factory); | ||
else if(typeof exports === 'object') | ||
exports["FrintComponentUtils"] = factory(require("lodash/isPlainObject"), require("rxjs/observable/of"), require("rxjs/observable/merge"), require("rxjs/operator/concatMap"), require("rxjs/operator/scan")); | ||
exports["FrintComponentUtils"] = factory(require("lodash/isPlainObject"), require("rxjs/observable/of"), require("rxjs/observable/merge"), require("rxjs/operators/concatMap"), require("rxjs/operators/scan")); | ||
else | ||
root["FrintComponentUtils"] = factory(root["_"]["isPlainObject"], root["Rx"]["Observable"], root["Rx"]["Observable"], root["Rx"]["Observable"]["prototype"], root["Rx"]["Observable"]["prototype"]); | ||
root["FrintComponentUtils"] = factory(root["_"]["isPlainObject"], root["Rx"]["Observable"], root["Rx"]["Observable"], root["Rx"]["operators"], root["Rx"]["operators"]); | ||
})(this, function(__WEBPACK_EXTERNAL_MODULE_5__, __WEBPACK_EXTERNAL_MODULE_6__, __WEBPACK_EXTERNAL_MODULE_7__, __WEBPACK_EXTERNAL_MODULE_8__, __WEBPACK_EXTERNAL_MODULE_9__) { | ||
@@ -338,5 +338,3 @@ return /******/ (function(modules) { // webpackBootstrap | ||
mappers.forEach(function (mapperFn) { | ||
var _context; | ||
mappedObject$ = (_context = mappedObject$, _concatMap.concatMap).call(_context, function (object) { | ||
mappedObject$ = mappedObject$.pipe((0, _concatMap.concatMap)(function (object) { | ||
var result = mapperFn(object); | ||
@@ -349,3 +347,3 @@ | ||
return (0, _of.of)(result); | ||
}); | ||
})); | ||
}); | ||
@@ -377,7 +375,5 @@ | ||
value: function get$() { | ||
var _context2; | ||
return (_context2 = _merge.merge.apply(undefined, _toConsumableArray(this._observables)), _scan.scan).call(_context2, function (props, emitted) { | ||
return _merge.merge.apply(undefined, _toConsumableArray(this._observables)).pipe((0, _scan.scan)(function (props, emitted) { | ||
return _extends({}, props, emitted); | ||
}); | ||
})); | ||
} | ||
@@ -384,0 +380,0 @@ }]); |
@@ -1,1 +0,1 @@ | ||
!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t(require("lodash/isPlainObject"),require("rxjs/observable/of"),require("rxjs/observable/merge"),require("rxjs/operator/concatMap"),require("rxjs/operator/scan")):"function"==typeof define&&define.amd?define(["lodash/isPlainObject","rxjs/observable/of","rxjs/observable/merge","rxjs/operator/concatMap","rxjs/operator/scan"],t):"object"==typeof exports?exports.FrintComponentUtils=t(require("lodash/isPlainObject"),require("rxjs/observable/of"),require("rxjs/observable/merge"),require("rxjs/operator/concatMap"),require("rxjs/operator/scan")):e.FrintComponentUtils=t(e._.isPlainObject,e.Rx.Observable,e.Rx.Observable,e.Rx.Observable.prototype,e.Rx.Observable.prototype)}(this,function(e,t,r,n,o){return function(e){function t(n){if(r[n])return r[n].exports;var o=r[n]={i:n,l:!1,exports:{}};return e[n].call(o.exports,o,o.exports,t),o.l=!0,o.exports}var r={};return t.m=e,t.c=r,t.d=function(e,r,n){t.o(e,r)||Object.defineProperty(e,r,{configurable:!1,enumerable:!0,get:n})},t.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(r,"a",r),r},t.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},t.p="",t(t.s=2)}([function(e,t,r){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.default={app:null,component:null,initialize:function(){},beforeDestroy:function(){},getInitialData:function(){return{}},setData:function(e,t){},setDataWithCallback:function(e,t,r){this.setData(e,t),r()},getData:function(e){},getProp:function(e){},getProps:function(){},beforeMount:function(){},afterMount:function(){},beforeUpdate:function(){},shouldUpdate:function(e,t){},afterUpdate:function(){},getMountableComponent:function(e){return e.get("component")}},e.exports=t.default},function(e,t,r){"use strict";function n(e){return!(!e||"function"!=typeof e.subscribe)}Object.defineProperty(t,"__esModule",{value:!0}),t.default=n,e.exports=t.default},function(e,t,r){"use strict";function n(e){return e&&e.__esModule?e:{default:e}}Object.defineProperty(t,"__esModule",{value:!0});var o=r(3),u=n(o),a=r(0),i=n(a),s=r(1),f=n(s),c=r(4),l=n(c);t.default={composeHandlers:u.default,DefaultHandler:i.default,isObservable:f.default,streamProps:l.default},e.exports=t.default},function(e,t,r){"use strict";function n(){for(var e=this,t=arguments.length,r=Array(t),n=0;n<t;n++)r[n]=arguments[n];[a.default].concat(r).forEach(function(t){Object.keys(t).forEach(function(r){e[r]=t[r],"function"==typeof t[r]&&(e[r]=e[r].bind(e))})})}function o(){for(var e=arguments.length,t=Array(e),r=0;r<e;r++)t[r]=arguments[r];return new(Function.prototype.bind.apply(n,[null].concat(t)))}Object.defineProperty(t,"__esModule",{value:!0}),t.default=o;var u=r(0),a=function(e){return e&&e.__esModule?e:{default:e}}(u);e.exports=t.default},function(e,t,r){"use strict";function n(e){return e&&e.__esModule?e:{default:e}}function o(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function u(e,t,r){return t in e?Object.defineProperty(e,t,{value:r,enumerable:!0,configurable:!0,writable:!0}):e[t]=r,e}function a(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}function i(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};return new x(e)}Object.defineProperty(t,"__esModule",{value:!0});var s=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},f=function(){function e(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(t,r,n){return r&&e(t.prototype,r),n&&e(t,n),t}}();t.default=i;var c=r(5),l=n(c),p=r(6),b=r(7),d=r(8),v=r(9),h=r(1),y=n(h),x=function(){function e(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};a(this,e),this._observables=[(0,p.of)(t)]}return f(e,[{key:"_push",value:function(e){this._observables.push(e)}},{key:"set",value:function(e){for(var t=arguments.length,r=Array(t>1?t-1:0),n=1;n<t;n++)r[n-1]=arguments[n];return"string"==typeof e?this.setKey(e,r[0]):(0,l.default)(e)?this.setPlainObject(e):(0,y.default)(e)?this.setObservable.apply(this,[e].concat(r)):this}},{key:"setKey",value:function(e,t){return this._push((0,p.of)(u({},e,t))),this}},{key:"setPlainObject",value:function(e){return this._push((0,p.of)(e)),this}},{key:"setObservable",value:function(e){for(var t=e,r=arguments.length,n=Array(r>1?r-1:0),o=1;o<r;o++)n[o-1]=arguments[o];return n.forEach(function(e){var r;t=(r=t,d.concatMap).call(r,function(t){var r=e(t);return(0,y.default)(r)?r:(0,p.of)(r)})}),this._push(t),this}},{key:"setDispatch",value:function(e,t){var r={};return Object.keys(e).forEach(function(n){var o=e[n];r[n]=function(){return t.dispatch(o.apply(void 0,arguments))}}),this._push((0,p.of)(r)),this}},{key:"get$",value:function(){var e;return(e=b.merge.apply(void 0,o(this._observables)),v.scan).call(e,function(e,t){return s({},e,t)})}}]),e}();e.exports=t.default},function(t,r){t.exports=e},function(e,r){e.exports=t},function(e,t){e.exports=r},function(e,t){e.exports=n},function(e,t){e.exports=o}])}); | ||
!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t(require("lodash/isPlainObject"),require("rxjs/observable/of"),require("rxjs/observable/merge"),require("rxjs/operators/concatMap"),require("rxjs/operators/scan")):"function"==typeof define&&define.amd?define(["lodash/isPlainObject","rxjs/observable/of","rxjs/observable/merge","rxjs/operators/concatMap","rxjs/operators/scan"],t):"object"==typeof exports?exports.FrintComponentUtils=t(require("lodash/isPlainObject"),require("rxjs/observable/of"),require("rxjs/observable/merge"),require("rxjs/operators/concatMap"),require("rxjs/operators/scan")):e.FrintComponentUtils=t(e._.isPlainObject,e.Rx.Observable,e.Rx.Observable,e.Rx.operators,e.Rx.operators)}(this,function(e,t,r,n,o){return function(e){function t(n){if(r[n])return r[n].exports;var o=r[n]={i:n,l:!1,exports:{}};return e[n].call(o.exports,o,o.exports,t),o.l=!0,o.exports}var r={};return t.m=e,t.c=r,t.d=function(e,r,n){t.o(e,r)||Object.defineProperty(e,r,{configurable:!1,enumerable:!0,get:n})},t.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return t.d(r,"a",r),r},t.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},t.p="",t(t.s=2)}([function(e,t,r){"use strict";Object.defineProperty(t,"__esModule",{value:!0}),t.default={app:null,component:null,initialize:function(){},beforeDestroy:function(){},getInitialData:function(){return{}},setData:function(e,t){},setDataWithCallback:function(e,t,r){this.setData(e,t),r()},getData:function(e){},getProp:function(e){},getProps:function(){},beforeMount:function(){},afterMount:function(){},beforeUpdate:function(){},shouldUpdate:function(e,t){},afterUpdate:function(){},getMountableComponent:function(e){return e.get("component")}},e.exports=t.default},function(e,t,r){"use strict";function n(e){return!(!e||"function"!=typeof e.subscribe)}Object.defineProperty(t,"__esModule",{value:!0}),t.default=n,e.exports=t.default},function(e,t,r){"use strict";function n(e){return e&&e.__esModule?e:{default:e}}Object.defineProperty(t,"__esModule",{value:!0});var o=r(3),u=n(o),a=r(0),i=n(a),s=r(1),f=n(s),c=r(4),l=n(c);t.default={composeHandlers:u.default,DefaultHandler:i.default,isObservable:f.default,streamProps:l.default},e.exports=t.default},function(e,t,r){"use strict";function n(){for(var e=this,t=arguments.length,r=Array(t),n=0;n<t;n++)r[n]=arguments[n];[a.default].concat(r).forEach(function(t){Object.keys(t).forEach(function(r){e[r]=t[r],"function"==typeof t[r]&&(e[r]=e[r].bind(e))})})}function o(){for(var e=arguments.length,t=Array(e),r=0;r<e;r++)t[r]=arguments[r];return new(Function.prototype.bind.apply(n,[null].concat(t)))}Object.defineProperty(t,"__esModule",{value:!0}),t.default=o;var u=r(0),a=function(e){return e&&e.__esModule?e:{default:e}}(u);e.exports=t.default},function(e,t,r){"use strict";function n(e){return e&&e.__esModule?e:{default:e}}function o(e){if(Array.isArray(e)){for(var t=0,r=Array(e.length);t<e.length;t++)r[t]=e[t];return r}return Array.from(e)}function u(e,t,r){return t in e?Object.defineProperty(e,t,{value:r,enumerable:!0,configurable:!0,writable:!0}):e[t]=r,e}function a(e,t){if(!(e instanceof t))throw new TypeError("Cannot call a class as a function")}function i(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};return new x(e)}Object.defineProperty(t,"__esModule",{value:!0});var s=Object.assign||function(e){for(var t=1;t<arguments.length;t++){var r=arguments[t];for(var n in r)Object.prototype.hasOwnProperty.call(r,n)&&(e[n]=r[n])}return e},f=function(){function e(e,t){for(var r=0;r<t.length;r++){var n=t[r];n.enumerable=n.enumerable||!1,n.configurable=!0,"value"in n&&(n.writable=!0),Object.defineProperty(e,n.key,n)}}return function(t,r,n){return r&&e(t.prototype,r),n&&e(t,n),t}}();t.default=i;var c=r(5),l=n(c),p=r(6),b=r(7),d=r(8),v=r(9),h=r(1),y=n(h),x=function(){function e(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};a(this,e),this._observables=[(0,p.of)(t)]}return f(e,[{key:"_push",value:function(e){this._observables.push(e)}},{key:"set",value:function(e){for(var t=arguments.length,r=Array(t>1?t-1:0),n=1;n<t;n++)r[n-1]=arguments[n];return"string"==typeof e?this.setKey(e,r[0]):(0,l.default)(e)?this.setPlainObject(e):(0,y.default)(e)?this.setObservable.apply(this,[e].concat(r)):this}},{key:"setKey",value:function(e,t){return this._push((0,p.of)(u({},e,t))),this}},{key:"setPlainObject",value:function(e){return this._push((0,p.of)(e)),this}},{key:"setObservable",value:function(e){for(var t=e,r=arguments.length,n=Array(r>1?r-1:0),o=1;o<r;o++)n[o-1]=arguments[o];return n.forEach(function(e){t=t.pipe((0,d.concatMap)(function(t){var r=e(t);return(0,y.default)(r)?r:(0,p.of)(r)}))}),this._push(t),this}},{key:"setDispatch",value:function(e,t){var r={};return Object.keys(e).forEach(function(n){var o=e[n];r[n]=function(){return t.dispatch(o.apply(void 0,arguments))}}),this._push((0,p.of)(r)),this}},{key:"get$",value:function(){return b.merge.apply(void 0,o(this._observables)).pipe((0,v.scan)(function(e,t){return s({},e,t)}))}}]),e}();e.exports=t.default},function(t,r){t.exports=e},function(e,r){e.exports=t},function(e,t){e.exports=r},function(e,t){e.exports=n},function(e,t){e.exports=o}])}); |
@@ -21,5 +21,5 @@ 'use strict'; | ||
var _concatMap = require('rxjs/operator/concatMap'); | ||
var _concatMap = require('rxjs/operators/concatMap'); | ||
var _scan = require('rxjs/operator/scan'); | ||
var _scan = require('rxjs/operators/scan'); | ||
@@ -100,5 +100,3 @@ var _isObservable = require('./isObservable'); | ||
mappers.forEach(function (mapperFn) { | ||
var _context; | ||
mappedObject$ = (_context = mappedObject$, _concatMap.concatMap).call(_context, function (object) { | ||
mappedObject$ = mappedObject$.pipe((0, _concatMap.concatMap)(function (object) { | ||
var result = mapperFn(object); | ||
@@ -111,3 +109,3 @@ | ||
return (0, _of.of)(result); | ||
}); | ||
})); | ||
}); | ||
@@ -139,7 +137,5 @@ | ||
value: function get$() { | ||
var _context2; | ||
return (_context2 = _merge.merge.apply(undefined, _toConsumableArray(this._observables)), _scan.scan).call(_context2, function (props, emitted) { | ||
return _merge.merge.apply(undefined, _toConsumableArray(this._observables)).pipe((0, _scan.scan)(function (props, emitted) { | ||
return _extends({}, props, emitted); | ||
}); | ||
})); | ||
} | ||
@@ -146,0 +142,0 @@ }]); |
@@ -7,3 +7,3 @@ 'use strict'; | ||
var _last = require('rxjs/operator/last'); | ||
var _last = require('rxjs/operators/last'); | ||
@@ -38,4 +38,2 @@ var _streamProps = require('./streamProps'); | ||
it('streams plain object, by merging with default', function (done) { | ||
var _context; | ||
var streamer = (0, _streamProps2.default)({ | ||
@@ -51,3 +49,3 @@ key: 'value', | ||
(_context = streamer.get$(), _last.last).call(_context).subscribe(function (props) { | ||
streamer.get$().pipe((0, _last.last)()).subscribe(function (props) { | ||
(0, _chai.expect)(props).to.deep.equal({ | ||
@@ -64,4 +62,2 @@ key: 'value', | ||
it('streams key/value pairs, by merging with default', function (done) { | ||
var _context2; | ||
var streamer = (0, _streamProps2.default)({ | ||
@@ -74,3 +70,3 @@ key: 'value' | ||
(_context2 = streamer.get$(), _last.last).call(_context2).subscribe(function (props) { | ||
streamer.get$().pipe((0, _last.last)()).subscribe(function (props) { | ||
(0, _chai.expect)(props).to.deep.equal({ | ||
@@ -87,4 +83,2 @@ key: 'value', | ||
it('streams multiple observables with mappings, by merging with default', function (done) { | ||
var _context3; | ||
var streamer = (0, _streamProps2.default)({ | ||
@@ -115,3 +109,3 @@ key: 'value' | ||
(_context3 = streamer.get$(), _last.last).call(_context3).subscribe(function (props) { | ||
streamer.get$().pipe((0, _last.last)()).subscribe(function (props) { | ||
(0, _chai.expect)(props).to.deep.equal({ | ||
@@ -128,4 +122,2 @@ key: 'value', | ||
it('steams dispatchable actions against store', function (done) { | ||
var _context4; | ||
var streamer = (0, _streamProps2.default)(); | ||
@@ -149,3 +141,3 @@ var dispatchedPayload = void 0; | ||
(_context4 = streamer.get$(), _last.last).call(_context4).subscribe(function (props) { | ||
streamer.get$().pipe((0, _last.last)()).subscribe(function (props) { | ||
props.myAction('someValue'); | ||
@@ -152,0 +144,0 @@ |
{ | ||
"name": "frint-component-utils", | ||
"version": "3.3.1", | ||
"version": "4.0.0", | ||
"description": "Component utils package for Frint", | ||
@@ -32,7 +32,7 @@ "main": "lib/index.js", | ||
"lodash": "^4.13.1", | ||
"rxjs": "^5.2.0" | ||
"rxjs": "^5.5.0" | ||
}, | ||
"devDependencies": { | ||
"cross-env": "^5.0.5", | ||
"frint-config": "^3.3.1" | ||
"frint-config": "^4.0.0" | ||
}, | ||
@@ -39,0 +39,0 @@ "bugs": { |
41829
808
Updatedrxjs@^5.5.0