Compare commits

...

55 Commits

Author SHA1 Message Date
45fd82279e 3.0.4 2023-07-24 13:09:38 +02:00
110a2e27cc fix(core): update 2023-07-24 13:09:38 +02:00
a41652ba52 3.0.3 2023-07-12 10:57:25 +02:00
fad166c100 fix(core): update 2023-07-12 10:57:25 +02:00
ed6db60055 switch to new org scheme 2023-07-10 10:17:56 +02:00
0097f819a0 3.0.2 2023-06-11 22:15:29 +02:00
a3ed2e5dbd fix(core): update 2023-06-11 22:15:29 +02:00
f9e43be46a 3.0.1 2023-06-10 13:33:10 +02:00
ca22a417da fix(core): update 2023-06-10 13:33:09 +02:00
093b1dd7a9 3.0.0 2022-08-05 13:25:45 +02:00
3c1bfaa1f7 BREAKING CHANGE(core): switch to esm 2022-08-05 13:25:44 +02:00
83cd98022a 2.0.26 2022-08-05 12:50:38 +02:00
b06ceaa9bf fix(core): update 2022-08-05 12:50:37 +02:00
e8057c0c95 2.0.25 2022-01-24 21:48:32 +01:00
d389d180e5 fix(core): update 2022-01-24 21:48:32 +01:00
d92123dcb9 2.0.24 2022-01-24 07:37:53 +01:00
5d8f569339 fix(core): update 2022-01-24 07:37:52 +01:00
7168bd7ffd 2.0.23 2022-01-24 07:30:55 +01:00
5031d28c32 fix(core): update 2022-01-24 07:30:54 +01:00
4eaf91af3a 2.0.22 2022-01-24 07:08:25 +01:00
511396894d fix(core): update 2022-01-24 07:08:24 +01:00
a1bd0499a0 2.0.21 2022-01-24 07:06:38 +01:00
803c8a4d8f fix(core): update 2022-01-24 07:06:37 +01:00
d5a2b0a78e 2.0.20 2022-01-24 03:44:14 +01:00
5fdd756672 fix(core): update 2022-01-24 03:44:13 +01:00
5f7580b28f 2.0.19 2020-09-24 17:28:57 +00:00
bba7bb7eea fix(core): update 2020-09-24 17:28:57 +00:00
552cae9755 2.0.18 2020-07-12 01:53:33 +00:00
610c1d6beb fix(core): update 2020-07-12 01:53:32 +00:00
037e33caee 2.0.17 2020-06-26 00:57:14 +00:00
2400e61024 fix(core): update 2020-06-26 00:57:14 +00:00
0fe16f4fc4 2.0.16 2020-06-26 00:52:51 +00:00
fa8fb5b622 fix(core): update 2020-06-26 00:52:51 +00:00
389f502dd0 2.0.15 2020-05-27 20:12:26 +00:00
ea3e7dd2ab fix(core): update 2020-05-27 20:12:25 +00:00
e4ac6232b8 2.0.14 2020-05-27 19:56:52 +00:00
fd9c57dcd0 fix(core): update 2020-05-27 19:56:52 +00:00
090142cb16 2.0.13 2020-05-27 19:44:35 +00:00
b05a8e4fa4 fix(core): update 2020-05-27 19:44:35 +00:00
66ee8ba0df 2.0.12 2020-05-27 18:49:44 +00:00
f9d8175c8c fix(core): update 2020-05-27 18:49:44 +00:00
5e218e36a5 2.0.11 2020-05-27 18:30:28 +00:00
417772a1ec fix(core): update 2020-05-27 18:30:27 +00:00
e34d9f7cad 2.0.10 2020-05-27 17:26:32 +00:00
9908d759c6 fix(core): update 2020-05-27 17:26:32 +00:00
c4d48b17e9 2.0.9 2020-05-27 17:06:29 +00:00
3cf9396773 fix(core): update 2020-05-27 17:06:29 +00:00
3632941abc 2.0.8 2020-05-27 17:05:53 +00:00
b8d7653434 fix(core): update 2020-05-27 17:05:53 +00:00
f2b02a2f68 2.0.7 2020-05-27 17:05:18 +00:00
aa8e2a9ae4 fix(core): update 2020-05-27 17:05:18 +00:00
bfff3b4da5 2.0.6 2020-05-26 00:18:03 +00:00
5e2d11980c fix(core): update 2020-05-26 00:18:02 +00:00
71edd16d65 2.0.5 2019-09-10 07:26:50 +02:00
f572603e04 fix(core): update 2019-09-10 07:26:50 +02:00
19 changed files with 5280 additions and 1941 deletions

17
.gitignore vendored
View File

@ -1,5 +1,20 @@
.nogit/
node_modules/
# artifacts
coverage/
public/
pages/
# installs
node_modules/
# caches
.yarn/
.cache/
.rpt2_cache
# builds
dist/
dist_*/
# custom

View File

@ -1,137 +0,0 @@
# gitzone standard
image: hosttoday/ht-docker-node:npmci
cache:
paths:
- .npmci_cache/
key: "$CI_BUILD_STAGE"
stages:
- security
- test
- release
- metadata
# ====================
# security stage
# ====================
mirror:
stage: security
script:
- npmci git mirror
tags:
- docker
- notpriv
snyk:
stage: security
script:
- npmci npm prepare
- npmci command npm install -g snyk
- npmci command npm install --ignore-scripts
- npmci command snyk test
tags:
- docker
- notpriv
# ====================
# test stage
# ====================
testLEGACY:
stage: test
script:
- npmci npm prepare
- npmci node install legacy
- npmci npm install
- npmci npm test
coverage: /\d+.?\d+?\%\s*coverage/
tags:
- docker
- notpriv
allow_failure: true
testLTS:
stage: test
script:
- npmci npm prepare
- npmci node install lts
- npmci npm install
- npmci npm test
coverage: /\d+.?\d+?\%\s*coverage/
tags:
- docker
- notpriv
testSTABLE:
stage: test
script:
- npmci npm prepare
- npmci node install stable
- npmci npm install
- npmci npm test
coverage: /\d+.?\d+?\%\s*coverage/
tags:
- docker
- notpriv
release:
stage: release
script:
- npmci node install stable
- npmci npm publish
only:
- tags
tags:
- docker
- notpriv
# ====================
# metadata stage
# ====================
codequality:
stage: metadata
image: docker:stable
allow_failure: true
services:
- docker:stable-dind
script:
- export SP_VERSION=$(echo "$CI_SERVER_VERSION" | sed 's/^\([0-9]*\)\.\([0-9]*\).*/\1-\2-stable/')
- docker run
--env SOURCE_CODE="$PWD"
--volume "$PWD":/code
--volume /var/run/docker.sock:/var/run/docker.sock
"registry.gitlab.com/gitlab-org/security-products/codequality:$SP_VERSION" /code
artifacts:
paths: [codeclimate.json]
tags:
- docker
- priv
trigger:
stage: metadata
script:
- npmci trigger
only:
- tags
tags:
- docker
- notpriv
pages:
image: hosttoday/ht-docker-node:npmci
stage: metadata
script:
- npmci command npm install -g typedoc typescript
- npmci npm prepare
- npmci npm install
- npmci command typedoc --module "commonjs" --target "ES2016" --out public/ ts/
tags:
- docker
- notpriv
only:
- tags
artifacts:
expire_in: 1 week
paths:
- public
allow_failure: true

11
.vscode/launch.json vendored Normal file
View File

@ -0,0 +1,11 @@
{
"version": "0.2.0",
"configurations": [
{
"command": "npm test",
"name": "Run npm test",
"request": "launch",
"type": "node-terminal"
}
]
}

26
.vscode/settings.json vendored Normal file
View File

@ -0,0 +1,26 @@
{
"json.schemas": [
{
"fileMatch": ["/npmextra.json"],
"schema": {
"type": "object",
"properties": {
"npmci": {
"type": "object",
"description": "settings for npmci"
},
"gitzone": {
"type": "object",
"description": "settings for gitzone",
"properties": {
"projectType": {
"type": "string",
"enum": ["website", "element", "service", "npm", "wcc"]
}
}
}
}
}
}
]
}

View File

@ -5,5 +5,16 @@
},
"npmdocker": {
"command": "rm -r node_modules && yarn install && yarn test"
},
"gitzone": {
"projectType": "npm",
"module": {
"githost": "gitlab.com",
"gitscope": "push.rocks",
"gitrepo": "smartrx",
"description": "smart wrapper for rxjs",
"npmPackagename": "@push.rocks/smartrx",
"license": "MIT"
}
}
}
}

1678
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@ -1,29 +1,43 @@
{
"name": "@pushrocks/smartrx",
"version": "2.0.4",
"name": "@push.rocks/smartrx",
"version": "3.0.4",
"private": false,
"description": "smart wrapper for rxjs",
"main": "dist/index.js",
"typings": "dist/index.d.ts",
"main": "dist_ts/index.js",
"typings": "dist_ts/index.d.ts",
"type": "module",
"author": "Lossless GmbH",
"license": "MIT",
"scripts": {
"test": "(tstest test/)",
"build": "(tsbuild)"
"build": "(tsbuild --web && tsbundle npm)",
"buildDocs": "tsdoc"
},
"devDependencies": {
"@gitzone/tsbuild": "^2.1.17",
"@gitzone/tsrun": "^1.2.8",
"@gitzone/tstest": "^1.0.24",
"@pushrocks/tapbundle": "^3.0.13",
"@types/node": "^12.7.4",
"tslint": "^5.20.0",
"tslint-config-prettier": "^1.18.0"
"@gitzone/tsbuild": "^2.1.66",
"@gitzone/tsbundle": "^2.0.8",
"@gitzone/tsrun": "^1.2.44",
"@gitzone/tstest": "^1.0.77",
"@push.rocks/tapbundle": "^5.0.12",
"@types/node": "^20.4.4"
},
"dependencies": {
"@pushrocks/lik": "^3.0.11",
"@pushrocks/smartevent": "^2.0.3",
"@pushrocks/smartpromise": "^3.0.2",
"rxjs": "^6.5.3"
}
"@push.rocks/smartpromise": "^4.0.2",
"rxjs": "^7.8.1"
},
"files": [
"ts/**/*",
"ts_web/**/*",
"dist/**/*",
"dist_*/**/*",
"dist_ts/**/*",
"dist_ts_web/**/*",
"assets/**/*",
"cli.js",
"npmextra.json",
"readme.md"
],
"browserslist": [
"last 1 chrome versions"
]
}

5026
pnpm-lock.yaml generated Normal file

File diff suppressed because it is too large Load Diff

View File

@ -1,33 +1,39 @@
# smartrx
# @pushrocks/smartrx
smart wrapper for rxjs
## Availabililty
[![npm](https://pushrocks.gitlab.io/assets/repo-button-npm.svg)](https://www.npmjs.com/package/smartrx)
[![git](https://pushrocks.gitlab.io/assets/repo-button-git.svg)](https://GitLab.com/pushrocks/smartrx)
[![git](https://pushrocks.gitlab.io/assets/repo-button-mirror.svg)](https://github.com/pushrocks/smartrx)
[![docs](https://pushrocks.gitlab.io/assets/repo-button-docs.svg)](https://pushrocks.gitlab.io/smartrx/)
## Availabililty and Links
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartrx)
* [gitlab.com (source)](https://gitlab.com/pushrocks/smartrx)
* [github.com (source mirror)](https://github.com/pushrocks/smartrx)
* [docs (typedoc)](https://pushrocks.gitlab.io/smartrx/)
## Status for master
[![build status](https://GitLab.com/pushrocks/smartrx/badges/master/build.svg)](https://GitLab.com/pushrocks/smartrx/commits/master)
[![coverage report](https://GitLab.com/pushrocks/smartrx/badges/master/coverage.svg)](https://GitLab.com/pushrocks/smartrx/commits/master)
[![npm downloads per month](https://img.shields.io/npm/dm/smartrx.svg)](https://www.npmjs.com/package/smartrx)
[![Dependency Status](https://david-dm.org/pushrocks/smartrx.svg)](https://david-dm.org/pushrocks/smartrx)
[![bitHound Dependencies](https://www.bithound.io/github/pushrocks/smartrx/badges/dependencies.svg)](https://www.bithound.io/github/pushrocks/smartrx/master/dependencies/npm)
[![bitHound Code](https://www.bithound.io/github/pushrocks/smartrx/badges/code.svg)](https://www.bithound.io/github/pushrocks/smartrx)
[![TypeScript](https://img.shields.io/badge/TypeScript-2.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
[![node](https://img.shields.io/badge/node->=%206.x.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-standard-brightgreen.svg)](http://standardjs.com/)
Status Category | Status Badge
-- | --
GitLab Pipelines | [![pipeline status](https://gitlab.com/pushrocks/smartrx/badges/master/pipeline.svg)](https://lossless.cloud)
GitLab Pipline Test Coverage | [![coverage report](https://gitlab.com/pushrocks/smartrx/badges/master/coverage.svg)](https://lossless.cloud)
npm | [![npm downloads per month](https://badgen.net/npm/dy/@pushrocks/smartrx)](https://lossless.cloud)
Snyk | [![Known Vulnerabilities](https://badgen.net/snyk/pushrocks/smartrx)](https://lossless.cloud)
TypeScript Support | [![TypeScript](https://badgen.net/badge/TypeScript/>=%203.x/blue?icon=typescript)](https://lossless.cloud)
node Support | [![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](https://lossless.cloud)
PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/smartrx)](https://lossless.cloud)
PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/smartrx)](https://lossless.cloud)
BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/smartrx)](https://lossless.cloud)
Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)
## Usage
Use TypeScript for best in class instellisense.
For further information read the linked docs at the top of this README.
## Contribution
We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
For further information read the linked docs at the top of this readme.
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
> | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
[![repo-footer](https://pushrocks.gitlab.io/assets/repo-footer.svg)](https://push.rocks)
[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com)

View File

@ -1,15 +1,15 @@
import { tap, expect } from '@pushrocks/tapbundle';
import { tap, expect } from '@push.rocks/tapbundle';
import * as smartrx from '../ts/index';
import * as smartrx from '../ts/index.js';
tap.test('should create a valid instance of observableinstake', async () => {
const testObservableIntake = new smartrx.ObservableIntake();
expect(testObservableIntake).to.be.instanceOf(smartrx.ObservableIntake);
expect(testObservableIntake).toBeInstanceOf(smartrx.ObservableIntake);
});
tap.test('expect testObserservableIntake to push things', async tools => {
tap.test('expect testObserservableIntake to push things', async (tools) => {
const testObserservableIntake = new smartrx.ObservableIntake();
testObserservableIntake.subscribe(value => {
testObserservableIntake.subscribe((value: any) => {
console.log(value);
});
@ -19,13 +19,13 @@ tap.test('expect testObserservableIntake to push things', async tools => {
await testObserservableIntake.completed;
});
tap.test('expect testObserservableIntake to push things', async tools => {
tap.test('expect testObserservableIntake to push things', async (tools) => {
const testObserservableIntake = new smartrx.ObservableIntake();
testObserservableIntake.push('hi');
testObserservableIntake.push('wow');
testObserservableIntake.makeBuffered();
testObserservableIntake.push('jo');
testObserservableIntake.subscribe(value => {
testObserservableIntake.subscribe((value: any) => {
console.log(value);
testObserservableIntake.signalComplete();
});

View File

@ -1,11 +1,11 @@
// import test framework
import { expect, tap } from '@pushrocks/tapbundle';
import { expect, tap } from '@push.rocks/tapbundle';
import * as events from 'events';
import * as rx from 'rxjs';
import * as smartpromise from '@pushrocks/smartpromise';
import * as smartpromise from '@push.rocks/smartpromise';
// import the module
import * as smartrx from '../ts/index';
import * as smartrx from '../ts/index.js';
let testObservablemap: smartrx.Observablemap;
let testObservable1: rx.Observable<any>;
@ -15,20 +15,20 @@ let testEmitter: events.EventEmitter;
tap.test('should create an instance', async () => {
testObservablemap = new smartrx.Observablemap();
expect(testObservablemap).be.instanceof(smartrx.Observablemap);
expect(testObservablemap).toBeInstanceOf(smartrx.Observablemap);
});
tap.test('should accept a new emitter', async () => {
let done = smartpromise.defer();
testEmitter = new events.EventEmitter();
testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
testObservable1.subscribe(x => {
testObservable1 = testObservablemap.getSubjectForEmitterEvent(testEmitter, 'event1');
testObservable1.subscribe((x) => {
done.resolve();
});
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2');
expect(testObservable1 === testObservable2).to.be.true;
expect(testObservable1 === testObservable3).to.be.false;
testObservable2 = testObservablemap.getSubjectForEmitterEvent(testEmitter, 'event1');
testObservable3 = testObservablemap.getSubjectForEmitterEvent(testEmitter, 'event2');
expect(testObservable1 === testObservable2).toBeTrue();
expect(testObservable1 === testObservable3).toBeFalse();
testEmitter.emit('event1');
await done.promise;
});

8
ts/00_commitinfo_data.ts Normal file
View File

@ -0,0 +1,8 @@
/**
* autocreated commitinfo by @pushrocks/commitinfo
*/
export const commitinfo = {
name: '@push.rocks/smartrx',
version: '3.0.4',
description: 'smart wrapper for rxjs'
}

View File

@ -1,7 +1,5 @@
import * as plugins from './smartrx.plugins';
export * from './smartrx.classes.observablemap';
export * from './smartrx.classes.observableintake';
import * as rxjs from '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 };

View File

@ -1,42 +1,42 @@
import * as plugins from './smartrx.plugins';
import { Observable, Subscription } from 'rxjs';
import { Deferred } from '@pushrocks/smartpromise';
import * as plugins from './smartrx.plugins.js';
import * as rxjs from './smartrx.plugins.rxjs.js';
/**
* ObservableIntake
*/
export class ObservableIntake<T> {
public observable: Observable<T>;
public observable: rxjs.Observable<T>;
public completed: Promise<void>;
private completedDeffered: Deferred<void>;
private completedDeffered: plugins.smartpromise.Deferred<void>;
private observableFunctions: any = {
next: payloadArg => {
next: (payloadArg: T) => {
// nothing
},
complete: payloadArg => {
complete: (payloadArg: T) => {
// nothing
}
},
};
private generator = null;
private generator: Generator<T> = null;
private buffered = false;
private payloadBuffer = [];
private payloadBuffer: any[] = [];
constructor() {
this.observable = Observable.create(observerArg => {
this.observableFunctions.next = (...args) => {
return observerArg.next(...args);
this.observable = new rxjs.Observable((observerArg: rxjs.Observer<any>) => {
this.observableFunctions.next = (...args: any) => {
return observerArg.next(args);
};
this.observableFunctions.complete = (...args) => {
this.observableFunctions.complete = () => {
this.completedDeffered.resolve();
return observerArg.complete(...args);
return observerArg.complete();
};
});
this.completedDeffered = plugins.smartpromise.defer();
this.completed = this.completedDeffered.promise;
}
public setObservable(observableFunc) {
this.observable = observableFunc();
public setObservable(observableFunc: rxjs.Observable<any>) {
this.observable = observableFunc;
}
public push(payloadArg: T) {
@ -61,7 +61,7 @@ export class ObservableIntake<T> {
* sets a generator to query the next pushed value
* @param generatorArg
*/
public setGenerator(generatorArg) {
public setGenerator(generatorArg: Generator<T>) {
this.generator = generatorArg;
}
@ -69,7 +69,7 @@ export class ObservableIntake<T> {
this.buffered = true;
}
public subscribe(...args) {
public subscribe(...args: any) {
return this.observable.subscribe(...args);
}
@ -85,8 +85,8 @@ export class ObservableIntake<T> {
if (this.payloadBuffer.length > 0) {
this.internalPush(this.payloadBuffer.shift());
} else {
const nextPayload = this.generator();
this.internalPush(nextPayload);
const nextPayload = this.generator.next();
this.internalPush(nextPayload.value);
}
}
}
@ -99,7 +99,7 @@ export class ObservableIntake<T> {
this.observableFunctions.complete();
}
private internalPush(payloadArg) {
private internalPush(payloadArg: T) {
this.observableFunctions.next(payloadArg);
}
}

View File

@ -1,12 +1,16 @@
import * as plugins from './smartrx.plugins';
import { Observable, fromEvent } from 'rxjs';
import { Objectmap, Stringmap } from '@pushrocks/lik';
import * as plugins from './smartrx.plugins.js';
import * as rxjs from './smartrx.plugins.rxjs.js';
export interface IEventEmitter<T = any> {
on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void;
}
/**
* bundles an observable with an emitter
*/
export interface ObservableEmitterBundle {
observable: plugins.rxjs.Observable<any>;
emitter: plugins.events.EventEmitter;
export interface IObservableEventBundle<T> {
subject: rxjs.Subject<any>;
eventRef: T;
event: string;
}
@ -14,26 +18,56 @@ export interface ObservableEmitterBundle {
* manages observables by making sure that only one observable is regsitered per event
*/
export class Observablemap {
ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>();
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.
*/
getObservableForEmitterEvent(emitterArg: plugins.events.EventEmitter, eventArg: string) {
let existingBundle = this.ObservableEmitterBundleObjectmap.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 {
let emitterObservable = fromEvent(emitterArg, eventArg);
this.ObservableEmitterBundleObjectmap.add({
observable: emitterObservable,
emitter: emitterArg,
event: eventArg
});
return emitterObservable;
const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg);
const emitterSubject = new rxjs.Subject();
emitterObservable.subscribe(emitterSubject);
const newBundle: IObservableEventBundle<IEventEmitter> = {
subject: emitterSubject,
eventRef: emitterArg,
event: eventArg,
};
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;
}
}
}

View File

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

View File

@ -1,7 +1,3 @@
import * as events from 'events';
import * as lik from '@pushrocks/lik';
import * as rxjs from 'rxjs';
import * as smartevent from '@pushrocks/smartevent';
import * as smartpromise from '@pushrocks/smartpromise';
import * as smartpromise from '@push.rocks/smartpromise';
export { events, lik, rxjs, smartevent, smartpromise };
export { smartpromise };

10
tsconfig.json Normal file
View File

@ -0,0 +1,10 @@
{
"compilerOptions": {
"experimentalDecorators": true,
"useDefineForClassFields": false,
"target": "ES2022",
"module": "ES2022",
"moduleResolution": "nodenext",
"verbatimModuleSyntax": true,
}
}

View File

@ -1,17 +0,0 @@
{
"extends": ["tslint:latest", "tslint-config-prettier"],
"rules": {
"semicolon": [true, "always"],
"no-console": false,
"ordered-imports": false,
"object-literal-sort-keys": false,
"member-ordering": {
"options":{
"order": [
"static-method"
]
}
}
},
"defaultSeverity": "warning"
}