@pushrocks/smartrx - npm Package Compare versions

Comparing version 2.0.25 to 2.0.26

dist_ts/index.d.ts

@@ -1,4 +0,4 @@
-export * from './smartrx.classes.observablemap';
-export * from './smartrx.classes.observableintake';
-import * as rxjs from './smartrx.plugins.rxjs';
+export * from './smartrx.classes.observablemap.js';
+export * from './smartrx.classes.observableintake.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 export { rxjs };

dist_ts/index.js

@@ -1,31 +0,6 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
-};
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.rxjs = void 0;
-require("./smartrx.plugins");
-__exportStar(require("./smartrx.classes.observablemap"), exports);
-__exportStar(require("./smartrx.classes.observableintake"), exports);
-const rxjs = __importStar(require("./smartrx.plugins.rxjs"));
-exports.rxjs = rxjs;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsNkJBQTZDO0FBQzdDLGtFQUFnRDtBQUNoRCxxRUFBbUQ7QUFDbkQsNkRBQStDO0FBRTdDLG9CQUFJIn0=
+import './smartrx.plugins.js';
+export * from './smartrx.classes.observablemap.js';
+export * from './smartrx.classes.observableintake.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
+export { rxjs };
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxPQUF5QixzQkFBc0IsQ0FBQztBQUNoRCxjQUFjLG9DQUFvQyxDQUFDO0FBQ25ELGNBQWMsdUNBQXVDLENBQUM7QUFDdEQsT0FBTyxLQUFLLElBQUksTUFBTSwyQkFBMkIsQ0FBQztBQUNsRCxPQUFPLEVBQ0wsSUFBSSxFQUNMLENBQUEifQ==

dist_ts/smartrx.classes.observableintake.d.ts

@@ -1,2 +0,2 @@
-import * as rxjs from './smartrx.plugins.rxjs';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 /**
@@ -3,0 +3,0 @@ * ObservableIntake

dist_ts/smartrx.classes.observableintake.js

@@ -1,29 +0,7 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ObservableIntake = void 0;
-const plugins = __importStar(require("./smartrx.plugins"));
-const rxjs = __importStar(require("./smartrx.plugins.rxjs"));
+import * as plugins from './smartrx.plugins.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 /**
  * ObservableIntake
  */
-class ObservableIntake {
+export class ObservableIntake {
     constructor() {
@@ -41,3 +19,3 @@ this.observableFunctions = {
         this.payloadBuffer = [];
-        this.observable = rxjs.Observable.create((observerArg) => {
+        this.observable = new rxjs.Observable((observerArg) => {
             this.observableFunctions.next = (...args) => {
@@ -117,3 +95,2 @@ return observerArg.next(args);
 }
-exports.ObservableIntake = ObservableIntake;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVpbnRha2UuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZWludGFrZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsMkRBQTZDO0FBRTdDLDZEQUErQztBQUUvQzs7R0FFRztBQUNILE1BQWEsZ0JBQWdCO0lBZ0IzQjtRQVpRLHdCQUFtQixHQUFRO1lBQ2pDLElBQUksRUFBRSxDQUFDLFVBQWEsRUFBRSxFQUFFO2dCQUN0QixVQUFVO1lBQ1osQ0FBQztZQUNELFFBQVEsRUFBRSxDQUFDLFVBQWEsRUFBRSxFQUFFO2dCQUMxQixVQUFVO1lBQ1osQ0FBQztTQUNGLENBQUM7UUFDTSxjQUFTLEdBQWlCLElBQUksQ0FBQztRQUMvQixhQUFRLEdBQUcsS0FBSyxDQUFDO1FBQ2pCLGtCQUFhLEdBQVUsRUFBRSxDQUFDO1FBR2hDLElBQUksQ0FBQyxVQUFVLEdBQUcsSUFBSSxDQUFDLFVBQVUsQ0FBQyxNQUFNLENBQUMsQ0FBQyxXQUErQixFQUFFLEVBQUU7WUFDM0UsSUFBSSxDQUFDLG1CQUFtQixDQUFDLElBQUksR0FBRyxDQUFDLEdBQUcsSUFBUyxFQUFFLEVBQUU7Z0JBQy9DLE9BQU8sV0FBVyxDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQztZQUNoQyxDQUFDLENBQUM7WUFDRixJQUFJLENBQUMsbUJBQW1CLENBQUMsUUFBUSxHQUFHLEdBQUcsRUFBRTtnQkFDdkMsSUFBSSxDQUFDLGlCQUFpQixDQUFDLE9BQU8sRUFBRSxDQUFDO2dCQUNqQyxPQUFPLFdBQVcsQ0FBQyxRQUFRLEVBQUUsQ0FBQztZQUNoQyxDQUFDLENBQUM7UUFDSixDQUFDLENBQUMsQ0FBQztRQUNILElBQUksQ0FBQyxpQkFBaUIsR0FBRyxPQUFPLENBQUMsWUFBWSxDQUFDLEtBQUssRUFBRSxDQUFDO1FBQ3RELElBQUksQ0FBQyxTQUFTLEdBQUcsSUFBSSxDQUFDLGlCQUFpQixDQUFDLE9BQU8sQ0FBQztJQUNsRCxDQUFDO0lBRU0sYUFBYSxDQUFDLGNBQW9DO1FBQ3ZELElBQUksQ0FBQyxVQUFVLEdBQUcsY0FBYyxDQUFDO0lBQ25DLENBQUM7SUFFTSxJQUFJLENBQUMsVUFBYTtRQUN2QixJQUFJLElBQUksQ0FBQyxRQUFRLEVBQUU7WUFDakIsSUFBSSxDQUFDLGFBQWEsQ0FBQyxJQUFJLENBQUMsVUFBVSxDQUFDLENBQUM7U0FDckM7YUFBTTtZQUNMLElBQUksQ0FBQyxZQUFZLENBQUMsVUFBVSxDQUFDLENBQUM7U0FDL0I7SUFDSCxDQUFDO0lBRUQ7OztPQUdHO0lBQ0ksUUFBUSxDQUFDLGVBQW9CO1FBQ2xDLEtBQUssTUFBTSxJQUFJLElBQUksZUFBZSxFQUFFO1lBQ2xDLElBQUksQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLENBQUM7U0FDakI7SUFDSCxDQUFDO0lBRUQ7OztPQUdHO0lBQ0ksWUFBWSxDQUFDLFlBQTBCO1FBQzVDLElBQUksQ0FBQyxTQUFTLEdBQUcsWUFBWSxDQUFDO0lBQ2hDLENBQUM7SUFFTSxZQUFZO1FBQ2pCLElBQUksQ0FBQyxRQUFRLEdBQUcsSUFBSSxDQUFDO0lBQ3ZCLENBQUM7SUFFTSxTQUFTLENBQUMsR0FBRyxJQUFTO1FBQzNCLE9BQU8sSUFBSSxDQUFDLFVBQVUsQ0FBQyxTQUFTLENBQUMsR0FBRyxJQUFJLENBQUMsQ0FBQztJQUM1QyxDQUFDO0lBRUQ7OztPQUdHO0lBQ0ksT0FBTyxDQUFDLFVBQWtCO1FBQy9CLElBQUksVUFBVSxLQUFLLENBQUMsRUFBRTtZQUNwQixPQUFPO1NBQ1I7YUFBTTtZQUNMLEtBQUssSUFBSSxDQUFDLEdBQUcsQ0FBQyxFQUFFLENBQUMsS0FBSyxVQUFVLEVBQUUsQ0FBQyxFQUFFLEVBQUU7Z0JBQ3JDLElBQUksSUFBSSxDQUFDLGFBQWEsQ0FBQyxNQUFNLEdBQUcsQ0FBQyxFQUFFO29CQUNqQyxJQUFJLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxhQUFhLENBQUMsS0FBSyxFQUFFLENBQUMsQ0FBQztpQkFDL0M7cUJBQU07b0JBQ0wsTUFBTSxXQUFXLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBQyxJQUFJLEVBQUUsQ0FBQztvQkFDMUMsSUFBSSxDQUFDLFlBQVksQ0FBQyxXQUFXLENBQUMsS0FBSyxDQUFDLENBQUM7aUJBQ3RDO2FBQ0Y7U0FDRjtJQUNILENBQUM7SUFFRDs7T0FFRztJQUNJLGNBQWM7UUFDbkIsSUFBSSxDQUFDLG1CQUFtQixDQUFDLFFBQVEsRUFBRSxDQUFDO0lBQ3RDLENBQUM7SUFFTyxZQUFZLENBQUMsVUFBYTtRQUNoQyxJQUFJLENBQUMsbUJBQW1CLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQyxDQUFDO0lBQzVDLENBQUM7Q0FDRjtBQWpHRCw0Q0FpR0MifQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVpbnRha2UuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZWludGFrZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxPQUFPLEtBQUssT0FBTyxNQUFNLHNCQUFzQixDQUFDO0FBRWhELE9BQU8sS0FBSyxJQUFJLE1BQU0sMkJBQTJCLENBQUM7QUFFbEQ7O0dBRUc7QUFDSCxNQUFNLE9BQU8sZ0JBQWdCO0lBZ0IzQjtRQVpRLHdCQUFtQixHQUFRO1lBQ2pDLElBQUksRUFBRSxDQUFDLFVBQWEsRUFBRSxFQUFFO2dCQUN0QixVQUFVO1lBQ1osQ0FBQztZQUNELFFBQVEsRUFBRSxDQUFDLFVBQWEsRUFBRSxFQUFFO2dCQUMxQixVQUFVO1lBQ1osQ0FBQztTQUNGLENBQUM7UUFDTSxjQUFTLEdBQWlCLElBQUksQ0FBQztRQUMvQixhQUFRLEdBQUcsS0FBSyxDQUFDO1FBQ2pCLGtCQUFhLEdBQVUsRUFBRSxDQUFDO1FBR2hDLElBQUksQ0FBQyxVQUFVLEdBQUcsSUFBSSxJQUFJLENBQUMsVUFBVSxDQUFDLENBQUMsV0FBK0IsRUFBRSxFQUFFO1lBQ3hFLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxJQUFJLEdBQUcsQ0FBQyxHQUFHLElBQVMsRUFBRSxFQUFFO2dCQUMvQyxPQUFPLFdBQVcsQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLENBQUM7WUFDaEMsQ0FBQyxDQUFDO1lBQ0YsSUFBSSxDQUFDLG1CQUFtQixDQUFDLFFBQVEsR0FBRyxHQUFHLEVBQUU7Z0JBQ3ZDLElBQUksQ0FBQyxpQkFBaUIsQ0FBQyxPQUFPLEVBQUUsQ0FBQztnQkFDakMsT0FBTyxXQUFXLENBQUMsUUFBUSxFQUFFLENBQUM7WUFDaEMsQ0FBQyxDQUFDO1FBQ0osQ0FBQyxDQUFDLENBQUM7UUFDSCxJQUFJLENBQUMsaUJBQWlCLEdBQUcsT0FBTyxDQUFDLFlBQVksQ0FBQyxLQUFLLEVBQUUsQ0FBQztRQUN0RCxJQUFJLENBQUMsU0FBUyxHQUFHLElBQUksQ0FBQyxpQkFBaUIsQ0FBQyxPQUFPLENBQUM7SUFDbEQsQ0FBQztJQUVNLGFBQWEsQ0FBQyxjQUFvQztRQUN2RCxJQUFJLENBQUMsVUFBVSxHQUFHLGNBQWMsQ0FBQztJQUNuQyxDQUFDO0lBRU0sSUFBSSxDQUFDLFVBQWE7UUFDdkIsSUFBSSxJQUFJLENBQUMsUUFBUSxFQUFFO1lBQ2pCLElBQUksQ0FBQyxhQUFhLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQyxDQUFDO1NBQ3JDO2FBQU07WUFDTCxJQUFJLENBQUMsWUFBWSxDQUFDLFVBQVUsQ0FBQyxDQUFDO1NBQy9CO0lBQ0gsQ0FBQztJQUVEOzs7T0FHRztJQUNJLFFBQVEsQ0FBQyxlQUFvQjtRQUNsQyxLQUFLLE1BQU0sSUFBSSxJQUFJLGVBQWUsRUFBRTtZQUNsQyxJQUFJLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxDQUFDO1NBQ2pCO0lBQ0gsQ0FBQztJQUVEOzs7T0FHRztJQUNJLFlBQVksQ0FBQyxZQUEwQjtRQUM1QyxJQUFJLENBQUMsU0FBUyxHQUFHLFlBQVksQ0FBQztJQUNoQyxDQUFDO0lBRU0sWUFBWTtRQUNqQixJQUFJLENBQUMsUUFBUSxHQUFHLElBQUksQ0FBQztJQUN2QixDQUFDO0lBRU0sU0FBUyxDQUFDLEdBQUcsSUFBUztRQUMzQixPQUFPLElBQUksQ0FBQyxVQUFVLENBQUMsU0FBUyxDQUFDLEdBQUcsSUFBSSxDQUFDLENBQUM7SUFDNUMsQ0FBQztJQUVEOzs7T0FHRztJQUNJLE9BQU8sQ0FBQyxVQUFrQjtRQUMvQixJQUFJLFVBQVUsS0FBSyxDQUFDLEVBQUU7WUFDcEIsT0FBTztTQUNSO2FBQU07WUFDTCxLQUFLLElBQUksQ0FBQyxHQUFHLENBQUMsRUFBRSxDQUFDLEtBQUssVUFBVSxFQUFFLENBQUMsRUFBRSxFQUFFO2dCQUNyQyxJQUFJLElBQUksQ0FBQyxhQUFhLENBQUMsTUFBTSxHQUFHLENBQUMsRUFBRTtvQkFDakMsSUFBSSxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsYUFBYSxDQUFDLEtBQUssRUFBRSxDQUFDLENBQUM7aUJBQy9DO3FCQUFNO29CQUNMLE1BQU0sV0FBVyxHQUFHLElBQUksQ0FBQyxTQUFTLENBQUMsSUFBSSxFQUFFLENBQUM7b0JBQzFDLElBQUksQ0FBQyxZQUFZLENBQUMsV0FBVyxDQUFDLEtBQUssQ0FBQyxDQUFDO2lCQUN0QzthQUNGO1NBQ0Y7SUFDSCxDQUFDO0lBRUQ7O09BRUc7SUFDSSxjQUFjO1FBQ25CLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxRQUFRLEVBQUUsQ0FBQztJQUN0QyxDQUFDO0lBRU8sWUFBWSxDQUFDLFVBQWE7UUFDaEMsSUFBSSxDQUFDLG1CQUFtQixDQUFDLElBQUksQ0FBQyxVQUFVLENBQUMsQ0FBQztJQUM1QyxDQUFDO0NBQ0YifQ==

dist_ts/smartrx.classes.observablemap.d.ts

@@ -1,2 +0,2 @@
-import * as rxjs from './smartrx.plugins.rxjs';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 export interface IEventEmitter<T = any> {
@@ -8,5 +8,5 @@ on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void;
  */
-export interface IObservableEmitterBundle {
-    observable: rxjs.Observable<any>;
-    emitter: IEventEmitter<unknown>;
+export interface IObservableEventBundle<T> {
+    subject: rxjs.Subject<any>;
+    eventRef: T;
     event: string;
@@ -18,8 +18,10 @@ }
 export declare class Observablemap {
-    observableEmitterBundleArray: IObservableEmitterBundle[];
+    observableEventEmitterBundleArray: IObservableEventBundle<IEventEmitter<unknown>>[];
+    observableEventTargetBundleArray: IObservableEventBundle<EventTarget>[];
     /**
-     * creates a new observable if not yet registered for the same event.
+     * creates a hot subject if not yet registered for the event.
      * In case event has been registered before the same observable is returned.
      */
-    getObservableForEmitterEvent<T>(emitterArg: IEventEmitter<T>, eventArg: string): rxjs.Observable<any>;
+    getSubjectForEmitterEvent<T>(emitterArg: IEventEmitter<T>, eventArg: string): rxjs.Subject<T>;
+    getSubjectForEventTarget<T>(eventTargetArg: EventTarget, eventNameArg: string): rxjs.Subject<T>;
 }

dist_ts/smartrx.classes.observablemap.js

@@ -1,55 +0,54 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.Observablemap = void 0;
-require("./smartrx.plugins");
-const rxjs = __importStar(require("./smartrx.plugins.rxjs"));
+import './smartrx.plugins.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 /**
  * manages observables by making sure that only one observable is regsitered per event
  */
-class Observablemap {
+export class Observablemap {
     constructor() {
-        this.observableEmitterBundleArray = new Array();
+        this.observableEventEmitterBundleArray = new Array();
+        this.observableEventTargetBundleArray = new Array();
     }
     /**
-     * creates a new observable if not yet registered for the same event.
+     * creates a hot subject if not yet registered for the event.
      * In case event has been registered before the same observable is returned.
      */
-    getObservableForEmitterEvent(emitterArg, eventArg) {
-        const existingBundle = this.observableEmitterBundleArray.find((bundleArg) => {
-            return bundleArg.emitter === emitterArg && bundleArg.event === eventArg;
+    getSubjectForEmitterEvent(emitterArg, eventArg) {
+        const existingBundle = this.observableEventEmitterBundleArray.find((bundleArg) => {
+            return bundleArg.eventRef === emitterArg && bundleArg.event === eventArg;
         });
         if (existingBundle) {
-            return existingBundle.observable;
+            return existingBundle.subject;
         }
         else {
             const emitterObservable = rxjs.fromEvent(emitterArg, eventArg);
-            this.observableEmitterBundleArray.push({
-                observable: emitterObservable,
-                emitter: emitterArg,
+            const emitterSubject = new rxjs.Subject();
+            emitterObservable.subscribe(emitterSubject);
+            const newBundle = {
+                subject: emitterSubject,
+                eventRef: emitterArg,
                 event: eventArg,
-            });
-            return emitterObservable;
+            };
+            this.observableEventEmitterBundleArray.push(newBundle);
+            return newBundle.subject;
         }
     }
+    getSubjectForEventTarget(eventTargetArg, eventNameArg) {
+        const existingBundle = this.observableEventTargetBundleArray.find((bundleArg) => {
+            return bundleArg.eventRef === eventTargetArg && bundleArg.event === eventNameArg;
+        });
+        if (existingBundle) {
+            return existingBundle.subject;
+        }
+        else {
+            const emitterSubject = new rxjs.Subject();
+            const newBundle = {
+                subject: emitterSubject,
+                eventRef: eventTargetArg,
+                event: eventNameArg,
+            };
+            this.observableEventTargetBundleArray.push(newBundle);
+            return newBundle.subject;
+        }
+    }
 }
-exports.Observablemap = Observablemap;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVtYXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZW1hcC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O0FBQUEsNkJBQTZDO0FBQzdDLDZEQUErQztBQWUvQzs7R0FFRztBQUNILE1BQWEsYUFBYTtJQUExQjtRQUNTLGlDQUE0QixHQUFHLElBQUksS0FBSyxFQUE0QixDQUFDO0lBc0I5RSxDQUFDO0lBcEJDOzs7T0FHRztJQUNJLDRCQUE0QixDQUFJLFVBQTRCLEVBQUUsUUFBZ0I7UUFDbkYsTUFBTSxjQUFjLEdBQUcsSUFBSSxDQUFDLDRCQUE0QixDQUFDLElBQUksQ0FBQyxDQUFDLFNBQVMsRUFBRSxFQUFFO1lBQzFFLE9BQU8sU0FBUyxDQUFDLE9BQU8sS0FBSyxVQUFVLElBQUksU0FBUyxDQUFDLEtBQUssS0FBSyxRQUFRLENBQUM7UUFDMUUsQ0FBQyxDQUFDLENBQUM7UUFDSCxJQUFJLGNBQWMsRUFBRTtZQUNsQixPQUFPLGNBQWMsQ0FBQyxVQUFVLENBQUM7U0FDbEM7YUFBTTtZQUNMLE1BQU0saUJBQWlCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBSSxVQUFpQixFQUFFLFFBQVEsQ0FBQyxDQUFDO1lBQ3pFLElBQUksQ0FBQyw0QkFBNEIsQ0FBQyxJQUFJLENBQUM7Z0JBQ3JDLFVBQVUsRUFBRSxpQkFBaUI7Z0JBQzdCLE9BQU8sRUFBRSxVQUFVO2dCQUNuQixLQUFLLEVBQUUsUUFBUTthQUNoQixDQUFDLENBQUM7WUFDSCxPQUFPLGlCQUFpQixDQUFDO1NBQzFCO0lBQ0gsQ0FBQztDQUNGO0FBdkJELHNDQXVCQyJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5jbGFzc2VzLm9ic2VydmFibGVtYXAuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LmNsYXNzZXMub2JzZXJ2YWJsZW1hcC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxPQUF5QixzQkFBc0IsQ0FBQztBQUNoRCxPQUFPLEtBQUssSUFBSSxNQUFNLDJCQUEyQixDQUFDO0FBZWxEOztHQUVHO0FBQ0gsTUFBTSxPQUFPLGFBQWE7SUFBMUI7UUFDUyxzQ0FBaUMsR0FBRyxJQUFJLEtBQUssRUFFakQsQ0FBQztRQUNHLHFDQUFnQyxHQUFHLElBQUksS0FBSyxFQUF1QyxDQUFDO0lBaUQ3RixDQUFDO0lBL0NDOzs7T0FHRztJQUNJLHlCQUF5QixDQUM5QixVQUE0QixFQUM1QixRQUFnQjtRQUVoQixNQUFNLGNBQWMsR0FBRyxJQUFJLENBQUMsaUNBQWlDLENBQUMsSUFBSSxDQUFDLENBQUMsU0FBUyxFQUFFLEVBQUU7WUFDL0UsT0FBTyxTQUFTLENBQUMsUUFBUSxLQUFLLFVBQVUsSUFBSSxTQUFTLENBQUMsS0FBSyxLQUFLLFFBQVEsQ0FBQztRQUMzRSxDQUFDLENBQUMsQ0FBQztRQUNILElBQUksY0FBYyxFQUFFO1lBQ2xCLE9BQU8sY0FBYyxDQUFDLE9BQU8sQ0FBQztTQUMvQjthQUFNO1lBQ0wsTUFBTSxpQkFBaUIsR0FBRyxJQUFJLENBQUMsU0FBUyxDQUFJLFVBQWlCLEVBQUUsUUFBUSxDQUFDLENBQUM7WUFDekUsTUFBTSxjQUFjLEdBQUcsSUFBSSxJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7WUFDMUMsaUJBQWlCLENBQUMsU0FBUyxDQUFDLGNBQWMsQ0FBQyxDQUFDO1lBQzVDLE1BQU0sU0FBUyxHQUEwQztnQkFDdkQsT0FBTyxFQUFFLGNBQWM7Z0JBQ3ZCLFFBQVEsRUFBRSxVQUFVO2dCQUNwQixLQUFLLEVBQUUsUUFBUTthQUNoQixDQUFDO1lBQ0YsSUFBSSxDQUFDLGlDQUFpQyxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsQ0FBQztZQUN2RCxPQUFPLFNBQVMsQ0FBQyxPQUFPLENBQUM7U0FDMUI7SUFDSCxDQUFDO0lBRU0sd0JBQXdCLENBQzdCLGNBQTJCLEVBQzNCLFlBQW9CO1FBRXBCLE1BQU0sY0FBYyxHQUFHLElBQUksQ0FBQyxnQ0FBZ0MsQ0FBQyxJQUFJLENBQUMsQ0FBQyxTQUFTLEVBQUUsRUFBRTtZQUM5RSxPQUFPLFNBQVMsQ0FBQyxRQUFRLEtBQUssY0FBYyxJQUFJLFNBQVMsQ0FBQyxLQUFLLEtBQUssWUFBWSxDQUFDO1FBQ25GLENBQUMsQ0FBQyxDQUFDO1FBQ0gsSUFBSSxjQUFjLEVBQUU7WUFDbEIsT0FBTyxjQUFjLENBQUMsT0FBTyxDQUFDO1NBQy9CO2FBQU07WUFDTCxNQUFNLGNBQWMsR0FBRyxJQUFJLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztZQUMxQyxNQUFNLFNBQVMsR0FBd0M7Z0JBQ3JELE9BQU8sRUFBRSxjQUFjO2dCQUN2QixRQUFRLEVBQUUsY0FBYztnQkFDeEIsS0FBSyxFQUFFLFlBQVk7YUFDcEIsQ0FBQztZQUNGLElBQUksQ0FBQyxnQ0FBZ0MsQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLENBQUM7WUFDdEQsT0FBTyxTQUFTLENBQUMsT0FBTyxDQUFDO1NBQzFCO0lBQ0gsQ0FBQztDQUNGIn0=

dist_ts/smartrx.plugins.js

@@ -1,25 +0,3 @@
-"use strict";
-var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
-}) : (function(o, m, k, k2) {
-    if (k2 === undefined) k2 = k;
-    o[k2] = m[k];
-}));
-var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
-    Object.defineProperty(o, "default", { enumerable: true, value: v });
-}) : function(o, v) {
-    o["default"] = v;
-});
-var __importStar = (this && this.__importStar) || function (mod) {
-    if (mod && mod.__esModule) return mod;
-    var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
-    __setModuleDefault(result, mod);
-    return result;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.smartpromise = void 0;
-const smartpromise = __importStar(require("@pushrocks/smartpromise"));
-exports.smartpromise = smartpromise;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRyeC5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7QUFBQSxzRUFBd0Q7QUFFL0Msb0NBQVkifQ==
+import * as smartpromise from '@pushrocks/smartpromise';
+export { smartpromise };
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRyeC5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLE9BQU8sS0FBSyxZQUFZLE1BQU0seUJBQXlCLENBQUM7QUFFeEQsT0FBTyxFQUFFLFlBQVksRUFBRSxDQUFDIn0=

dist_ts/smartrx.plugins.rxjs.d.ts

@@ -1,2 +0,3 @@
-export { Observable, Subject, fromEvent, ReplaySubject, Subscription, Observer } from 'rxjs';
+export { Observable, Subject, fromEvent, ReplaySubject, Subscription } from 'rxjs';
+export type { Observer } from 'rxjs';
 import { startWith, takeUntil, map, debounce, debounceTime } from 'rxjs/operators';
@@ -3,0 +4,0 @@ export declare const ops: {

dist_ts/smartrx.plugins.rxjs.js

@@ -1,19 +0,11 @@
-"use strict";
 // this file is intended to keep the bundle size down
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.ops = exports.Subscription = exports.ReplaySubject = exports.fromEvent = exports.Subject = exports.Observable = void 0;
-var rxjs_1 = require("rxjs");
-Object.defineProperty(exports, "Observable", { enumerable: true, get: function () { return rxjs_1.Observable; } });
-Object.defineProperty(exports, "Subject", { enumerable: true, get: function () { return rxjs_1.Subject; } });
-Object.defineProperty(exports, "fromEvent", { enumerable: true, get: function () { return rxjs_1.fromEvent; } });
-Object.defineProperty(exports, "ReplaySubject", { enumerable: true, get: function () { return rxjs_1.ReplaySubject; } });
-Object.defineProperty(exports, "Subscription", { enumerable: true, get: function () { return rxjs_1.Subscription; } });
-const operators_1 = require("rxjs/operators");
-exports.ops = {
-    debounce: operators_1.debounce,
-    debounceTime: operators_1.debounceTime,
-    map: operators_1.map,
-    startWith: operators_1.startWith,
-    takeUntil: operators_1.takeUntil,
+export { Observable, Subject, fromEvent, ReplaySubject, Subscription } from 'rxjs';
+import { startWith, takeUntil, map, debounce, debounceTime } from 'rxjs/operators';
+export const ops = {
+    debounce,
+    debounceTime,
+    map,
+    startWith,
+    takeUntil,
 };
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLnJ4anMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LnBsdWdpbnMucnhqcy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEscURBQXFEOzs7QUFFckQsNkJBQTZGO0FBQXBGLGtHQUFBLFVBQVUsT0FBQTtBQUFFLCtGQUFBLE9BQU8sT0FBQTtBQUFFLGlHQUFBLFNBQVMsT0FBQTtBQUFFLHFHQUFBLGFBQWEsT0FBQTtBQUFFLG9HQUFBLFlBQVksT0FBQTtBQUVwRSw4Q0FBbUY7QUFFdEUsUUFBQSxHQUFHLEdBQUc7SUFDakIsUUFBUSxFQUFSLG9CQUFRO0lBQ1IsWUFBWSxFQUFaLHdCQUFZO0lBQ1osR0FBRyxFQUFILGVBQUc7SUFDSCxTQUFTLEVBQVQscUJBQVM7SUFDVCxTQUFTLEVBQVQscUJBQVM7Q0FDVixDQUFDIn0=
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRyeC5wbHVnaW5zLnJ4anMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHJ4LnBsdWdpbnMucnhqcy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxxREFBcUQ7QUFFckQsT0FBTyxFQUFFLFVBQVUsRUFBRSxPQUFPLEVBQUUsU0FBUyxFQUFFLGFBQWEsRUFBRSxZQUFZLEVBQUUsTUFBTSxNQUFNLENBQUM7QUFJbkYsT0FBTyxFQUFFLFNBQVMsRUFBRSxTQUFTLEVBQUUsR0FBRyxFQUFFLFFBQVEsRUFBRSxZQUFZLEVBQUUsTUFBTSxnQkFBZ0IsQ0FBQztBQUVuRixNQUFNLENBQUMsTUFBTSxHQUFHLEdBQUc7SUFDakIsUUFBUTtJQUNSLFlBQVk7SUFDWixHQUFHO0lBQ0gsU0FBUztJQUNULFNBQVM7Q0FDVixDQUFDIn0=

package.json

 {
   "name": "@pushrocks/smartrx",
-  "version": "2.0.25",
+  "version": "2.0.26",
   "private": false,
@@ -8,2 +8,3 @@ "description": "smart wrapper for rxjs",
   "typings": "dist_ts/index.d.ts",
+  "type": "module",
   "author": "Lossless GmbH",
@@ -16,8 +17,8 @@ "license": "MIT",
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.1.29",
-    "@gitzone/tsbundle": "^1.0.89",
-    "@gitzone/tsrun": "^1.2.18",
-    "@gitzone/tstest": "^1.0.60",
-    "@pushrocks/tapbundle": "^4.0.0",
-    "@types/node": "^17.0.10",
+    "@gitzone/tsbuild": "^2.1.65",
+    "@gitzone/tsbundle": "^2.0.7",
+    "@gitzone/tsrun": "^1.2.37",
+    "@gitzone/tstest": "^1.0.73",
+    "@pushrocks/tapbundle": "^5.0.4",
+    "@types/node": "^18.6.4",
     "tslint": "^6.1.3",
@@ -27,4 +28,4 @@ "tslint-config-prettier": "^1.18.0"
   "dependencies": {
-    "@pushrocks/smartpromise": "^3.1.6",
-    "rxjs": "^7.5.2"
+    "@pushrocks/smartpromise": "^3.1.7",
+    "rxjs": "^7.5.6"
   },
@@ -31,0 +32,0 @@ "files": [

ts/index.ts

@@ -1,7 +0,7 @@
-import * as plugins from './smartrx.plugins';
-export * from './smartrx.classes.observablemap';
-export * from './smartrx.classes.observableintake';
-import * as rxjs from './smartrx.plugins.rxjs';
+import * as plugins from './smartrx.plugins.js';
+export * from './smartrx.classes.observablemap.js';
+export * from './smartrx.classes.observableintake.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 export {
   rxjs
 }

ts/smartrx.classes.observableintake.ts

@@ -1,4 +0,4 @@
-import * as plugins from './smartrx.plugins';
+import * as plugins from './smartrx.plugins.js';
 
-import * as rxjs from './smartrx.plugins.rxjs';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 
@@ -25,3 +25,3 @@ /**
   constructor() {
-    this.observable = rxjs.Observable.create((observerArg: rxjs.Observer<any>) => {
+    this.observable = new rxjs.Observable((observerArg: rxjs.Observer<any>) => {
       this.observableFunctions.next = (...args: any) => {
@@ -28,0 +28,0 @@ return observerArg.next(args);

ts/smartrx.classes.observablemap.ts

@@ -1,3 +0,3 @@
-import * as plugins from './smartrx.plugins';
-import * as rxjs from './smartrx.plugins.rxjs';
+import * as plugins from './smartrx.plugins.js';
+import * as rxjs from './smartrx.plugins.rxjs.js';
 
@@ -11,5 +11,5 @@ export interface IEventEmitter<T = any> {
  */
-export interface IObservableEmitterBundle {
-  observable: rxjs.Observable<any>;
-  emitter: IEventEmitter<unknown>;
+export interface IObservableEventBundle<T> {
+  subject: rxjs.Subject<any>;
+  eventRef: T;
   event: string;
@@ -22,24 +22,54 @@ }
 export class Observablemap {
-  public observableEmitterBundleArray = new Array<IObservableEmitterBundle>();
+  public observableEventEmitterBundleArray = new Array<
+    IObservableEventBundle<IEventEmitter<unknown>>
+  >();
+  public observableEventTargetBundleArray = new Array<IObservableEventBundle<EventTarget>>();
 
   /**
-   * creates a new observable if not yet registered for the same event.
+   * creates a hot subject if not yet registered for the event.
    * In case event has been registered before the same observable is returned.
    */
-  public getObservableForEmitterEvent<T>(emitterArg: IEventEmitter<T>, eventArg: string) {
-    const existingBundle = this.observableEmitterBundleArray.find((bundleArg) => {
-      return bundleArg.emitter === emitterArg && bundleArg.event === eventArg;
+  public getSubjectForEmitterEvent<T>(
+    emitterArg: IEventEmitter<T>,
+    eventArg: string
+  ): rxjs.Subject<T> {
+    const existingBundle = this.observableEventEmitterBundleArray.find((bundleArg) => {
+      return bundleArg.eventRef === emitterArg && bundleArg.event === eventArg;
     });
     if (existingBundle) {
-      return existingBundle.observable;
+      return existingBundle.subject;
     } else {
       const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg);
-      this.observableEmitterBundleArray.push({
-        observable: emitterObservable,
-        emitter: emitterArg,
+      const emitterSubject = new rxjs.Subject();
+      emitterObservable.subscribe(emitterSubject);
+      const newBundle: IObservableEventBundle<IEventEmitter> = {
+        subject: emitterSubject,
+        eventRef: emitterArg,
         event: eventArg,
-      });
-      return emitterObservable;
+      };
+      this.observableEventEmitterBundleArray.push(newBundle);
+      return newBundle.subject;
     }
   }
+
+  public getSubjectForEventTarget<T>(
+    eventTargetArg: EventTarget,
+    eventNameArg: string
+  ): rxjs.Subject<T> {
+    const existingBundle = this.observableEventTargetBundleArray.find((bundleArg) => {
+      return bundleArg.eventRef === eventTargetArg && bundleArg.event === eventNameArg;
+    });
+    if (existingBundle) {
+      return existingBundle.subject;
+    } else {
+      const emitterSubject = new rxjs.Subject();
+      const newBundle: IObservableEventBundle<EventTarget> = {
+        subject: emitterSubject,
+        eventRef: eventTargetArg,
+        event: eventNameArg,
+      };
+      this.observableEventTargetBundleArray.push(newBundle);
+      return newBundle.subject;
+    }
+  }
 }

ts/smartrx.plugins.rxjs.ts

 // this file is intended to keep the bundle size down
 
-export { Observable, Subject, fromEvent, ReplaySubject, Subscription, Observer } from 'rxjs';
+export { Observable, Subject, fromEvent, ReplaySubject, Subscription } from 'rxjs';
 
+export type { Observer } from 'rxjs';
+
 import { startWith, takeUntil, map, debounce, debounceTime } from 'rxjs/operators';
@@ -6,0 +8,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

187023

increased by388.44%

Number of package files

31

increased by19.23%

Lines of code

3064

increased by327.93%

Is type module

Yes

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• Updated@pushrocks/smartpromise@^3.1.7

• Updatedrxjs@^7.5.6