@pushrocks/smartrx
Advanced tools
Comparing version 2.0.24 to 2.0.25
@@ -1,2 +0,1 @@ | ||
import * as plugins from './smartrx.plugins'; | ||
import * as rxjs from './smartrx.plugins.rxjs'; | ||
@@ -18,3 +17,3 @@ export interface IEventEmitter<T = any> { | ||
export declare class Observablemap { | ||
observableEmitterBundleObjectmap: plugins.lik.ObjectMap<IObservableEmitterBundle>; | ||
observableEmitterBundleArray: IObservableEmitterBundle[]; | ||
/** | ||
@@ -21,0 +20,0 @@ * creates a new observable if not yet registered for the same event. |
@@ -23,3 +23,3 @@ "use strict"; | ||
exports.Observablemap = void 0; | ||
const plugins = __importStar(require("./smartrx.plugins")); | ||
require("./smartrx.plugins"); | ||
const rxjs = __importStar(require("./smartrx.plugins.rxjs")); | ||
@@ -31,3 +31,3 @@ /** | ||
constructor() { | ||
this.observableEmitterBundleObjectmap = new plugins.lik.ObjectMap(); | ||
this.observableEmitterBundleArray = new Array(); | ||
} | ||
@@ -39,3 +39,3 @@ /** | ||
getObservableForEmitterEvent(emitterArg, eventArg) { | ||
const existingBundle = this.observableEmitterBundleObjectmap.findSync((bundleArg) => { | ||
const existingBundle = this.observableEmitterBundleArray.find((bundleArg) => { | ||
return bundleArg.emitter === emitterArg && bundleArg.event === eventArg; | ||
@@ -48,3 +48,3 @@ }); | ||
const emitterObservable = rxjs.fromEvent(emitterArg, eventArg); | ||
this.observableEmitterBundleObjectmap.add({ | ||
this.observableEmitterBundleArray.push({ | ||
observable: emitterObservable, | ||
@@ -59,2 +59,2 @@ emitter: emitterArg, | ||
exports.Observablemap = Observablemap; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVtYXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZW1hcC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsMkRBQTZDO0FBQzdDLDZEQUErQztBQWUvQzs7R0FFRztBQUNILE1BQWEsYUFBYTtJQUExQjtRQUNTLHFDQUFnQyxHQUFHLElBQUksT0FBTyxDQUFDLEdBQUcsQ0FBQyxTQUFTLEVBQTRCLENBQUM7SUFzQmxHLENBQUM7SUFwQkM7OztPQUdHO0lBQ0ksNEJBQTRCLENBQUksVUFBNEIsRUFBRSxRQUFnQjtRQUNuRixNQUFNLGNBQWMsR0FBRyxJQUFJLENBQUMsZ0NBQWdDLENBQUMsUUFBUSxDQUFDLENBQUMsU0FBUyxFQUFFLEVBQUU7WUFDbEYsT0FBTyxTQUFTLENBQUMsT0FBTyxLQUFLLFVBQVUsSUFBSSxTQUFTLENBQUMsS0FBSyxLQUFLLFFBQVEsQ0FBQztRQUMxRSxDQUFDLENBQUMsQ0FBQztRQUNILElBQUksY0FBYyxFQUFFO1lBQ2xCLE9BQU8sY0FBYyxDQUFDLFVBQVUsQ0FBQztTQUNsQzthQUFNO1lBQ0wsTUFBTSxpQkFBaUIsR0FBRyxJQUFJLENBQUMsU0FBUyxDQUFJLFVBQWlCLEVBQUUsUUFBUSxDQUFDLENBQUM7WUFDekUsSUFBSSxDQUFDLGdDQUFnQyxDQUFDLEdBQUcsQ0FBQztnQkFDeEMsVUFBVSxFQUFFLGlCQUFpQjtnQkFDN0IsT0FBTyxFQUFFLFVBQVU7Z0JBQ25CLEtBQUssRUFBRSxRQUFRO2FBQ2hCLENBQUMsQ0FBQztZQUNILE9BQU8saUJBQWlCLENBQUM7U0FDMUI7SUFDSCxDQUFDO0NBQ0Y7QUF2QkQsc0NBdUJDIn0= | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVtYXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZW1hcC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsNkJBQTZDO0FBQzdDLDZEQUErQztBQWUvQzs7R0FFRztBQUNILE1BQWEsYUFBYTtJQUExQjtRQUNTLGlDQUE0QixHQUFHLElBQUksS0FBSyxFQUE0QixDQUFDO0lBc0I5RSxDQUFDO0lBcEJDOzs7T0FHRztJQUNJLDRCQUE0QixDQUFJLFVBQTRCLEVBQUUsUUFBZ0I7UUFDbkYsTUFBTSxjQUFjLEdBQUcsSUFBSSxDQUFDLDRCQUE0QixDQUFDLElBQUksQ0FBQyxDQUFDLFNBQVMsRUFBRSxFQUFFO1lBQzFFLE9BQU8sU0FBUyxDQUFDLE9BQU8sS0FBSyxVQUFVLElBQUksU0FBUyxDQUFDLEtBQUssS0FBSyxRQUFRLENBQUM7UUFDMUUsQ0FBQyxDQUFDLENBQUM7UUFDSCxJQUFJLGNBQWMsRUFBRTtZQUNsQixPQUFPLGNBQWMsQ0FBQyxVQUFVLENBQUM7U0FDbEM7YUFBTTtZQUNMLE1BQU0saUJBQWlCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBSSxVQUFpQixFQUFFLFFBQVEsQ0FBQyxDQUFDO1lBQ3pFLElBQUksQ0FBQyw0QkFBNEIsQ0FBQyxJQUFJLENBQUM7Z0JBQ3JDLFVBQVUsRUFBRSxpQkFBaUI7Z0JBQzdCLE9BQU8sRUFBRSxVQUFVO2dCQUNuQixLQUFLLEVBQUUsUUFBUTthQUNoQixDQUFDLENBQUM7WUFDSCxPQUFPLGlCQUFpQixDQUFDO1NBQzFCO0lBQ0gsQ0FBQztDQUNGO0FBdkJELHNDQXVCQyJ9 |
@@ -1,3 +0,2 @@ | ||
import * as lik from '@pushrocks/lik'; | ||
import * as smartpromise from '@pushrocks/smartpromise'; | ||
export { lik, smartpromise }; | ||
export { smartpromise }; |
@@ -22,7 +22,5 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.smartpromise = exports.lik = void 0; | ||
const lik = __importStar(require("@pushrocks/lik")); | ||
exports.lik = lik; | ||
exports.smartpromise = void 0; | ||
const smartpromise = __importStar(require("@pushrocks/smartpromise")); | ||
exports.smartpromise = smartpromise; | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRyeC5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFBQSxvREFBc0M7QUFHN0Isa0JBQUc7QUFGWixzRUFBd0Q7QUFFMUMsb0NBQVkifQ== | ||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRyeC5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFBQSxzRUFBd0Q7QUFFL0Msb0NBQVkifQ== |
{ | ||
"name": "@pushrocks/smartrx", | ||
"version": "2.0.24", | ||
"version": "2.0.25", | ||
"private": false, | ||
@@ -25,3 +25,2 @@ "description": "smart wrapper for rxjs", | ||
"dependencies": { | ||
"@pushrocks/lik": "^5.0.1", | ||
"@pushrocks/smartpromise": "^3.1.6", | ||
@@ -28,0 +27,0 @@ "rxjs": "^7.5.2" |
@@ -21,3 +21,3 @@ import * as plugins from './smartrx.plugins'; | ||
export class Observablemap { | ||
public observableEmitterBundleObjectmap = new plugins.lik.ObjectMap<IObservableEmitterBundle>(); | ||
public observableEmitterBundleArray = new Array<IObservableEmitterBundle>(); | ||
@@ -29,3 +29,3 @@ /** | ||
public getObservableForEmitterEvent<T>(emitterArg: IEventEmitter<T>, eventArg: string) { | ||
const existingBundle = this.observableEmitterBundleObjectmap.findSync((bundleArg) => { | ||
const existingBundle = this.observableEmitterBundleArray.find((bundleArg) => { | ||
return bundleArg.emitter === emitterArg && bundleArg.event === eventArg; | ||
@@ -37,3 +37,3 @@ }); | ||
const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg); | ||
this.observableEmitterBundleObjectmap.add({ | ||
this.observableEmitterBundleArray.push({ | ||
observable: emitterObservable, | ||
@@ -40,0 +40,0 @@ emitter: emitterArg, |
@@ -1,4 +0,3 @@ | ||
import * as lik from '@pushrocks/lik'; | ||
import * as smartpromise from '@pushrocks/smartpromise'; | ||
export { lik, smartpromise }; | ||
export { smartpromise }; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
2
38290
716
- Removed@pushrocks/lik@^5.0.1
- Removed@pushrocks/lik@5.0.7(transitive)
- Removed@pushrocks/smartdelay@2.0.13(transitive)
- Removed@pushrocks/smartmatch@1.0.7(transitive)
- Removed@pushrocks/smartrx@2.0.27(transitive)
- Removed@pushrocks/smarttime@3.0.50(transitive)
- Removed@types/minimatch@3.0.5(transitive)
- Removedcall-bind@1.0.7(transitive)
- Removedcroner@4.4.1(transitive)
- Removeddayjs@1.11.13(transitive)
- Removeddefine-data-property@1.1.4(transitive)
- Removeddefine-properties@1.2.1(transitive)
- Removedes-define-property@1.0.0(transitive)
- Removedes-errors@1.3.0(transitive)
- Removedescape-string-regexp@4.0.0(transitive)
- Removedfunction-bind@1.1.2(transitive)
- Removedget-intrinsic@1.2.4(transitive)
- Removedgopd@1.0.1(transitive)
- Removedhas-property-descriptors@1.0.2(transitive)
- Removedhas-proto@1.0.3(transitive)
- Removedhas-symbols@1.0.3(transitive)
- Removedhasown@2.0.2(transitive)
- Removedis-nan@1.3.2(transitive)
- Removedmatcher@3.0.0(transitive)
- Removedobject-keys@1.1.1(transitive)
- Removedparse-ms@2.1.0(transitive)
- Removedpretty-ms@7.0.1(transitive)
- Removedset-function-length@1.2.2(transitive)
- Removedsymbol-tree@3.2.4(transitive)