Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@pushrocks/smartrx

Package Overview
Dependencies
Maintainers
1
Versions
27
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@pushrocks/smartrx - npm Package Compare versions

Comparing version 2.0.24 to 2.0.25

3

dist_ts/smartrx.classes.observablemap.d.ts

@@ -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 };
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc