Compare commits
48 Commits
Author | SHA1 | Date | |
---|---|---|---|
e8057c0c95 | |||
d389d180e5 | |||
d92123dcb9 | |||
5d8f569339 | |||
7168bd7ffd | |||
5031d28c32 | |||
4eaf91af3a | |||
511396894d | |||
a1bd0499a0 | |||
803c8a4d8f | |||
d5a2b0a78e | |||
5fdd756672 | |||
5f7580b28f | |||
bba7bb7eea | |||
552cae9755 | |||
610c1d6beb | |||
037e33caee | |||
2400e61024 | |||
0fe16f4fc4 | |||
fa8fb5b622 | |||
389f502dd0 | |||
ea3e7dd2ab | |||
e4ac6232b8 | |||
fd9c57dcd0 | |||
090142cb16 | |||
b05a8e4fa4 | |||
66ee8ba0df | |||
f9d8175c8c | |||
5e218e36a5 | |||
417772a1ec | |||
e34d9f7cad | |||
9908d759c6 | |||
c4d48b17e9 | |||
3cf9396773 | |||
3632941abc | |||
b8d7653434 | |||
f2b02a2f68 | |||
aa8e2a9ae4 | |||
bfff3b4da5 | |||
5e2d11980c | |||
71edd16d65 | |||
f572603e04 | |||
71a1cde491 | |||
487cd53c3b | |||
e050031313 | |||
cbbb31e0e7 | |||
a758196705 | |||
951d260103 |
17
.gitignore
vendored
17
.gitignore
vendored
@ -1,5 +1,20 @@
|
|||||||
.nogit/
|
.nogit/
|
||||||
node_modules/
|
|
||||||
|
# artifacts
|
||||||
coverage/
|
coverage/
|
||||||
public/
|
public/
|
||||||
pages/
|
pages/
|
||||||
|
|
||||||
|
# installs
|
||||||
|
node_modules/
|
||||||
|
|
||||||
|
# caches
|
||||||
|
.yarn/
|
||||||
|
.cache/
|
||||||
|
.rpt2_cache
|
||||||
|
|
||||||
|
# builds
|
||||||
|
dist/
|
||||||
|
dist_*/
|
||||||
|
|
||||||
|
# custom
|
150
.gitlab-ci.yml
150
.gitlab-ci.yml
@ -1,16 +1,16 @@
|
|||||||
# gitzone standard
|
# gitzone ci_default
|
||||||
image: hosttoday/ht-docker-node:npmci
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
|
|
||||||
cache:
|
cache:
|
||||||
paths:
|
paths:
|
||||||
- .npmci_cache/
|
- .npmci_cache/
|
||||||
key: "$CI_BUILD_STAGE"
|
key: '$CI_BUILD_STAGE'
|
||||||
|
|
||||||
stages:
|
stages:
|
||||||
- security
|
- security
|
||||||
- test
|
- test
|
||||||
- release
|
- release
|
||||||
- metadata
|
- metadata
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# security stage
|
# security stage
|
||||||
@ -18,114 +18,114 @@ stages:
|
|||||||
mirror:
|
mirror:
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci git mirror
|
- npmci git mirror
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
snyk:
|
auditProductionDependencies:
|
||||||
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
stage: security
|
stage: security
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci command npm install -g snyk
|
- npmci command npm install --production --ignore-scripts
|
||||||
- npmci command npm install --ignore-scripts
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
- npmci command snyk test
|
- npmci command npm audit --audit-level=high --only=prod --production
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
|
||||||
|
auditDevDependencies:
|
||||||
|
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||||
|
stage: security
|
||||||
|
script:
|
||||||
|
- npmci npm prepare
|
||||||
|
- npmci command npm install --ignore-scripts
|
||||||
|
- npmci command npm config set registry https://registry.npmjs.org
|
||||||
|
- npmci command npm audit --audit-level=high --only=dev
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
allow_failure: true
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# test stage
|
# 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:
|
testStable:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci node install lts
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci npm test
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
|
||||||
|
testBuild:
|
||||||
testSTABLE:
|
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci npm test
|
- npmci command npm run build
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
coverage: /\d+.?\d+?\%\s*coverage/
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
|
||||||
|
|
||||||
release:
|
release:
|
||||||
stage: release
|
stage: release
|
||||||
script:
|
script:
|
||||||
- npmci node install stable
|
- npmci node install stable
|
||||||
- npmci npm publish
|
- npmci npm publish
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
# ====================
|
# ====================
|
||||||
# metadata stage
|
# metadata stage
|
||||||
# ====================
|
# ====================
|
||||||
codequality:
|
codequality:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
image: docker:stable
|
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
services:
|
only:
|
||||||
- docker:stable-dind
|
- tags
|
||||||
script:
|
script:
|
||||||
- export SP_VERSION=$(echo "$CI_SERVER_VERSION" | sed 's/^\([0-9]*\)\.\([0-9]*\).*/\1-\2-stable/')
|
- npmci command npm install -g tslint typescript
|
||||||
- docker run
|
- npmci npm prepare
|
||||||
--env SOURCE_CODE="$PWD"
|
- npmci npm install
|
||||||
--volume "$PWD":/code
|
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
||||||
--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:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- priv
|
- docker
|
||||||
|
- priv
|
||||||
|
|
||||||
trigger:
|
trigger:
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci trigger
|
- npmci trigger
|
||||||
only:
|
only:
|
||||||
- tags
|
- tags
|
||||||
tags:
|
tags:
|
||||||
- docker
|
- lossless
|
||||||
- notpriv
|
- docker
|
||||||
|
- notpriv
|
||||||
|
|
||||||
pages:
|
pages:
|
||||||
image: hosttoday/ht-docker-node:npmci
|
|
||||||
stage: metadata
|
stage: metadata
|
||||||
script:
|
script:
|
||||||
- npmci command npm install -g typedoc typescript
|
- npmci node install lts
|
||||||
|
- npmci command npm install -g @gitzone/tsdoc
|
||||||
- npmci npm prepare
|
- npmci npm prepare
|
||||||
- npmci npm install
|
- npmci npm install
|
||||||
- npmci command typedoc --module "commonjs" --target "ES2016" --out public/ ts/
|
- npmci command tsdoc
|
||||||
tags:
|
tags:
|
||||||
|
- lossless
|
||||||
- docker
|
- docker
|
||||||
- notpriv
|
- notpriv
|
||||||
only:
|
only:
|
||||||
@ -133,15 +133,5 @@ pages:
|
|||||||
artifacts:
|
artifacts:
|
||||||
expire_in: 1 week
|
expire_in: 1 week
|
||||||
paths:
|
paths:
|
||||||
- public
|
- public
|
||||||
allow_failure: true
|
|
||||||
|
|
||||||
windowsCompatibility:
|
|
||||||
image: stefanscherer/node-windows:10-build-tools
|
|
||||||
stage: metadata
|
|
||||||
script:
|
|
||||||
- npm install & npm test
|
|
||||||
coverage: /\d+.?\d+?\%\s*coverage/
|
|
||||||
tags:
|
|
||||||
- windows
|
|
||||||
allow_failure: true
|
allow_failure: true
|
||||||
|
29
.vscode/launch.json
vendored
Normal file
29
.vscode/launch.json
vendored
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
{
|
||||||
|
"version": "0.2.0",
|
||||||
|
"configurations": [
|
||||||
|
{
|
||||||
|
"name": "current file",
|
||||||
|
"type": "node",
|
||||||
|
"request": "launch",
|
||||||
|
"args": [
|
||||||
|
"${relativeFile}"
|
||||||
|
],
|
||||||
|
"runtimeArgs": ["-r", "@gitzone/tsrun"],
|
||||||
|
"cwd": "${workspaceRoot}",
|
||||||
|
"protocol": "inspector",
|
||||||
|
"internalConsoleOptions": "openOnSessionStart"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "test.ts",
|
||||||
|
"type": "node",
|
||||||
|
"request": "launch",
|
||||||
|
"args": [
|
||||||
|
"test/test.ts"
|
||||||
|
],
|
||||||
|
"runtimeArgs": ["-r", "@gitzone/tsrun"],
|
||||||
|
"cwd": "${workspaceRoot}",
|
||||||
|
"protocol": "inspector",
|
||||||
|
"internalConsoleOptions": "openOnSessionStart"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
26
.vscode/settings.json
vendored
Normal file
26
.vscode/settings.json
vendored
Normal 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"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
@ -5,5 +5,16 @@
|
|||||||
},
|
},
|
||||||
"npmdocker": {
|
"npmdocker": {
|
||||||
"command": "rm -r node_modules && yarn install && yarn test"
|
"command": "rm -r node_modules && yarn install && yarn test"
|
||||||
|
},
|
||||||
|
"gitzone": {
|
||||||
|
"projectType": "npm",
|
||||||
|
"module": {
|
||||||
|
"githost": "gitlab.com",
|
||||||
|
"gitscope": "pushrocks",
|
||||||
|
"gitrepo": "smartrx",
|
||||||
|
"shortDescription": "smart wrapper for rxjs",
|
||||||
|
"npmPackagename": "@pushrocks/smartrx",
|
||||||
|
"license": "MIT"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
27161
package-lock.json
generated
27161
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
44
package.json
44
package.json
@ -1,27 +1,43 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrx",
|
"name": "@pushrocks/smartrx",
|
||||||
"version": "2.0.1",
|
"version": "2.0.25",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "smart wrapper for rxjs",
|
"description": "smart wrapper for rxjs",
|
||||||
"main": "dist/index.js",
|
"main": "dist_ts/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist_ts/index.d.ts",
|
||||||
"author": "Lossless GmbH",
|
"author": "Lossless GmbH",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "(tstest test/)",
|
"test": "(tstest test/)",
|
||||||
"build": "(tsbuild)"
|
"build": "(tsbuild --web && tsbundle npm)"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@gitzone/tsbuild": "^2.0.22",
|
"@gitzone/tsbuild": "^2.1.29",
|
||||||
"@gitzone/tsrun": "^1.1.12",
|
"@gitzone/tsbundle": "^1.0.89",
|
||||||
"@gitzone/tstest": "^1.0.15",
|
"@gitzone/tsrun": "^1.2.18",
|
||||||
"@pushrocks/tapbundle": "^3.0.7",
|
"@gitzone/tstest": "^1.0.60",
|
||||||
"@types/node": "^10.11.6"
|
"@pushrocks/tapbundle": "^4.0.0",
|
||||||
|
"@types/node": "^17.0.10",
|
||||||
|
"tslint": "^6.1.3",
|
||||||
|
"tslint-config-prettier": "^1.18.0"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@pushrocks/lik": "^3.0.1",
|
"@pushrocks/smartpromise": "^3.1.6",
|
||||||
"@pushrocks/smartpromise": "^2.0.5",
|
"rxjs": "^7.5.2"
|
||||||
"rxjs": "^6.3.3",
|
},
|
||||||
"smartevent": "^1.0.1"
|
"files": [
|
||||||
}
|
"ts/**/*",
|
||||||
|
"ts_web/**/*",
|
||||||
|
"dist/**/*",
|
||||||
|
"dist_*/**/*",
|
||||||
|
"dist_ts/**/*",
|
||||||
|
"dist_ts_web/**/*",
|
||||||
|
"assets/**/*",
|
||||||
|
"cli.js",
|
||||||
|
"npmextra.json",
|
||||||
|
"readme.md"
|
||||||
|
],
|
||||||
|
"browserslist": [
|
||||||
|
"last 1 chrome versions"
|
||||||
|
]
|
||||||
}
|
}
|
||||||
|
46
readme.md
46
readme.md
@ -1,33 +1,39 @@
|
|||||||
# smartrx
|
# @pushrocks/smartrx
|
||||||
|
|
||||||
smart wrapper for rxjs
|
smart wrapper for rxjs
|
||||||
|
|
||||||
## Availabililty
|
## Availabililty and Links
|
||||||
|
* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/smartrx)
|
||||||
[](https://www.npmjs.com/package/smartrx)
|
* [gitlab.com (source)](https://gitlab.com/pushrocks/smartrx)
|
||||||
[](https://GitLab.com/pushrocks/smartrx)
|
* [github.com (source mirror)](https://github.com/pushrocks/smartrx)
|
||||||
[](https://github.com/pushrocks/smartrx)
|
* [docs (typedoc)](https://pushrocks.gitlab.io/smartrx/)
|
||||||
[](https://pushrocks.gitlab.io/smartrx/)
|
|
||||||
|
|
||||||
## Status for master
|
## Status for master
|
||||||
|
|
||||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
Status Category | Status Badge
|
||||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
-- | --
|
||||||
[](https://www.npmjs.com/package/smartrx)
|
GitLab Pipelines | [](https://lossless.cloud)
|
||||||
[](https://david-dm.org/pushrocks/smartrx)
|
GitLab Pipline Test Coverage | [](https://lossless.cloud)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartrx/master/dependencies/npm)
|
npm | [](https://lossless.cloud)
|
||||||
[](https://www.bithound.io/github/pushrocks/smartrx)
|
Snyk | [](https://lossless.cloud)
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
TypeScript Support | [](https://lossless.cloud)
|
||||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
node Support | [](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||||
[](http://standardjs.com/)
|
Code Style | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (total standalone install weight) | [](https://lossless.cloud)
|
||||||
|
PackagePhobia (package size on registry) | [](https://lossless.cloud)
|
||||||
|
BundlePhobia (total size when bundled) | [](https://lossless.cloud)
|
||||||
|
Platform support | [](https://lossless.cloud) [](https://lossless.cloud)
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
|
|
||||||
Use TypeScript for best in class instellisense.
|
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)
|
> 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)
|
||||||
|
|
||||||
[](https://push.rocks)
|
[](https://maintainedby.lossless.com)
|
||||||
|
@ -4,12 +4,12 @@ import * as smartrx from '../ts/index';
|
|||||||
|
|
||||||
tap.test('should create a valid instance of observableinstake', async () => {
|
tap.test('should create a valid instance of observableinstake', async () => {
|
||||||
const testObservableIntake = new smartrx.ObservableIntake();
|
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();
|
const testObserservableIntake = new smartrx.ObservableIntake();
|
||||||
testObserservableIntake.subscribe(value => {
|
testObserservableIntake.subscribe((value: any) => {
|
||||||
console.log(value);
|
console.log(value);
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -19,13 +19,13 @@ tap.test('expect testObserservableIntake to push things', async tools => {
|
|||||||
await testObserservableIntake.completed;
|
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();
|
const testObserservableIntake = new smartrx.ObservableIntake();
|
||||||
testObserservableIntake.push('hi');
|
testObserservableIntake.push('hi');
|
||||||
testObserservableIntake.push('wow');
|
testObserservableIntake.push('wow');
|
||||||
testObserservableIntake.makeBuffered();
|
testObserservableIntake.makeBuffered();
|
||||||
testObserservableIntake.push('jo');
|
testObserservableIntake.push('jo');
|
||||||
testObserservableIntake.subscribe(value => {
|
testObserservableIntake.subscribe((value: any) => {
|
||||||
console.log(value);
|
console.log(value);
|
||||||
testObserservableIntake.signalComplete();
|
testObserservableIntake.signalComplete();
|
||||||
});
|
});
|
||||||
|
@ -15,20 +15,20 @@ let testEmitter: events.EventEmitter;
|
|||||||
|
|
||||||
tap.test('should create an instance', async () => {
|
tap.test('should create an instance', async () => {
|
||||||
testObservablemap = new smartrx.Observablemap();
|
testObservablemap = new smartrx.Observablemap();
|
||||||
expect(testObservablemap).be.instanceof(smartrx.Observablemap);
|
expect(testObservablemap).toBeInstanceOf(smartrx.Observablemap);
|
||||||
});
|
});
|
||||||
|
|
||||||
tap.test('should accept a new emitter', async () => {
|
tap.test('should accept a new emitter', async () => {
|
||||||
let done = smartpromise.defer();
|
let done = smartpromise.defer();
|
||||||
testEmitter = new events.EventEmitter();
|
testEmitter = new events.EventEmitter();
|
||||||
testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
||||||
testObservable1.subscribe(x => {
|
testObservable1.subscribe((x) => {
|
||||||
done.resolve();
|
done.resolve();
|
||||||
});
|
});
|
||||||
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
||||||
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2');
|
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2');
|
||||||
expect(testObservable1 === testObservable2).to.be.true;
|
expect(testObservable1 === testObservable2).toBeTrue();
|
||||||
expect(testObservable1 === testObservable3).to.be.false;
|
expect(testObservable1 === testObservable3).toBeFalse();
|
||||||
testEmitter.emit('event1');
|
testEmitter.emit('event1');
|
||||||
await done.promise;
|
await done.promise;
|
||||||
});
|
});
|
||||||
|
10
ts/index.ts
10
ts/index.ts
@ -1,9 +1,7 @@
|
|||||||
import * as plugins from './smartrx.plugins';
|
import * as plugins from './smartrx.plugins';
|
||||||
|
|
||||||
export let standardExport = 'Hi there! :) This is a exported string';
|
|
||||||
export * from './smartrx.classes.observablemap';
|
export * from './smartrx.classes.observablemap';
|
||||||
export * from './smartrx.classes.observableintake';
|
export * from './smartrx.classes.observableintake';
|
||||||
|
import * as rxjs from './smartrx.plugins.rxjs';
|
||||||
import * as rxjs from 'rxjs';
|
export {
|
||||||
|
rxjs
|
||||||
export { rxjs };
|
}
|
||||||
|
@ -1,45 +1,45 @@
|
|||||||
import * as plugins from './smartrx.plugins';
|
import * as plugins from './smartrx.plugins';
|
||||||
import { Observable, Subscription } from 'rxjs';
|
|
||||||
import { Deferred } from 'smartq';
|
import * as rxjs from './smartrx.plugins.rxjs';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* ObservableIntake
|
* ObservableIntake
|
||||||
*/
|
*/
|
||||||
export class ObservableIntake<T> {
|
export class ObservableIntake<T> {
|
||||||
observable: Observable<T>;
|
public observable: rxjs.Observable<T>;
|
||||||
completed: Promise<void>;
|
public completed: Promise<void>;
|
||||||
private completedDeffered: Deferred<void>;
|
private completedDeffered: plugins.smartpromise.Deferred<void>;
|
||||||
private observableFunctions: any = {
|
private observableFunctions: any = {
|
||||||
next: payloadArg => {
|
next: (payloadArg: T) => {
|
||||||
// nothing
|
// nothing
|
||||||
},
|
},
|
||||||
complete: payloadArg => {
|
complete: (payloadArg: T) => {
|
||||||
// nothing
|
// nothing
|
||||||
}
|
},
|
||||||
};
|
};
|
||||||
private generator = null;
|
private generator: Generator<T> = null;
|
||||||
private buffered = false;
|
private buffered = false;
|
||||||
private payloadBuffer = [];
|
private payloadBuffer: any[] = [];
|
||||||
|
|
||||||
constructor() {
|
constructor() {
|
||||||
this.observable = Observable.create(observerArg => {
|
this.observable = rxjs.Observable.create((observerArg: rxjs.Observer<any>) => {
|
||||||
this.observableFunctions.next = (...args) => {
|
this.observableFunctions.next = (...args: any) => {
|
||||||
return observerArg.next(...args);
|
return observerArg.next(args);
|
||||||
};
|
};
|
||||||
this.observableFunctions.complete = (...args) => {
|
this.observableFunctions.complete = () => {
|
||||||
this.completedDeffered.resolve();
|
this.completedDeffered.resolve();
|
||||||
return observerArg.complete(...args);
|
return observerArg.complete();
|
||||||
};
|
};
|
||||||
});
|
});
|
||||||
this.completedDeffered = plugins.smartpromise.defer();
|
this.completedDeffered = plugins.smartpromise.defer();
|
||||||
this.completed = this.completedDeffered.promise;
|
this.completed = this.completedDeffered.promise;
|
||||||
}
|
}
|
||||||
|
|
||||||
setObservable(observableFunc) {
|
public setObservable(observableFunc: rxjs.Observable<any>) {
|
||||||
this.observable = observableFunc();
|
this.observable = observableFunc;
|
||||||
}
|
}
|
||||||
|
|
||||||
push(payloadArg: T) {
|
public push(payloadArg: T) {
|
||||||
if (this.buffered) {
|
if (this.buffered) {
|
||||||
this.payloadBuffer.push(payloadArg);
|
this.payloadBuffer.push(payloadArg);
|
||||||
} else {
|
} else {
|
||||||
@ -51,8 +51,8 @@ export class ObservableIntake<T> {
|
|||||||
* pushes many payloads as array
|
* pushes many payloads as array
|
||||||
* @param payloadArgArray
|
* @param payloadArgArray
|
||||||
*/
|
*/
|
||||||
pushMany(payloadArgArray: T[]) {
|
public pushMany(payloadArgArray: T[]) {
|
||||||
for (let item of payloadArgArray) {
|
for (const item of payloadArgArray) {
|
||||||
this.push(item);
|
this.push(item);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -61,15 +61,15 @@ export class ObservableIntake<T> {
|
|||||||
* sets a generator to query the next pushed value
|
* sets a generator to query the next pushed value
|
||||||
* @param generatorArg
|
* @param generatorArg
|
||||||
*/
|
*/
|
||||||
setGenerator(generatorArg) {
|
public setGenerator(generatorArg: Generator<T>) {
|
||||||
this.generator = generatorArg;
|
this.generator = generatorArg;
|
||||||
}
|
}
|
||||||
|
|
||||||
makeBuffered() {
|
public makeBuffered() {
|
||||||
this.buffered = true;
|
this.buffered = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
subscribe(...args) {
|
public subscribe(...args: any) {
|
||||||
return this.observable.subscribe(...args);
|
return this.observable.subscribe(...args);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -77,7 +77,7 @@ export class ObservableIntake<T> {
|
|||||||
* request the next values in the quantity specified
|
* request the next values in the quantity specified
|
||||||
* @param howManyArg if a generator is set, of a buffer exists, this allows retrieving values
|
* @param howManyArg if a generator is set, of a buffer exists, this allows retrieving values
|
||||||
*/
|
*/
|
||||||
request(howManyArg: number) {
|
public request(howManyArg: number) {
|
||||||
if (howManyArg === 0) {
|
if (howManyArg === 0) {
|
||||||
return;
|
return;
|
||||||
} else {
|
} else {
|
||||||
@ -85,8 +85,8 @@ export class ObservableIntake<T> {
|
|||||||
if (this.payloadBuffer.length > 0) {
|
if (this.payloadBuffer.length > 0) {
|
||||||
this.internalPush(this.payloadBuffer.shift());
|
this.internalPush(this.payloadBuffer.shift());
|
||||||
} else {
|
} else {
|
||||||
const nextPayload = this.generator();
|
const nextPayload = this.generator.next();
|
||||||
this.internalPush(nextPayload);
|
this.internalPush(nextPayload.value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -95,11 +95,11 @@ export class ObservableIntake<T> {
|
|||||||
/**
|
/**
|
||||||
* signals the completion of this observable
|
* signals the completion of this observable
|
||||||
*/
|
*/
|
||||||
signalComplete() {
|
public signalComplete() {
|
||||||
this.observableFunctions.complete();
|
this.observableFunctions.complete();
|
||||||
}
|
}
|
||||||
|
|
||||||
private internalPush(payloadArg) {
|
private internalPush(payloadArg: T) {
|
||||||
this.observableFunctions.next(payloadArg);
|
this.observableFunctions.next(payloadArg);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,12 +1,16 @@
|
|||||||
import * as plugins from './smartrx.plugins';
|
import * as plugins from './smartrx.plugins';
|
||||||
import { Observable, fromEvent } from 'rxjs';
|
import * as rxjs from './smartrx.plugins.rxjs';
|
||||||
import { Objectmap, Stringmap } from '@pushrocks/lik';
|
|
||||||
|
export interface IEventEmitter<T = any> {
|
||||||
|
on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* bundles an observable with an emitter
|
* bundles an observable with an emitter
|
||||||
*/
|
*/
|
||||||
export interface ObservableEmitterBundle {
|
export interface IObservableEmitterBundle {
|
||||||
observable: plugins.rxjs.Observable<any>;
|
observable: rxjs.Observable<any>;
|
||||||
emitter: plugins.events.EventEmitter;
|
emitter: IEventEmitter<unknown>;
|
||||||
event: string;
|
event: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -14,24 +18,24 @@ export interface ObservableEmitterBundle {
|
|||||||
* manages observables by making sure that only one observable is regsitered per event
|
* manages observables by making sure that only one observable is regsitered per event
|
||||||
*/
|
*/
|
||||||
export class Observablemap {
|
export class Observablemap {
|
||||||
ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>();
|
public observableEmitterBundleArray = new Array<IObservableEmitterBundle>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* creates a new observable if not yet registered for the same event.
|
* creates a new observable if not yet registered for the same event.
|
||||||
* In case event has been registered before the same observable is returned.
|
* In case event has been registered before the same observable is returned.
|
||||||
*/
|
*/
|
||||||
getObservableForEmitterEvent(emitterArg: plugins.events.EventEmitter, eventArg: string) {
|
public getObservableForEmitterEvent<T>(emitterArg: IEventEmitter<T>, eventArg: string) {
|
||||||
let existingBundle = this.ObservableEmitterBundleObjectmap.find(bundleArg => {
|
const existingBundle = this.observableEmitterBundleArray.find((bundleArg) => {
|
||||||
return bundleArg.emitter === emitterArg && bundleArg.event === eventArg;
|
return bundleArg.emitter === emitterArg && bundleArg.event === eventArg;
|
||||||
});
|
});
|
||||||
if (existingBundle) {
|
if (existingBundle) {
|
||||||
return existingBundle.observable;
|
return existingBundle.observable;
|
||||||
} else {
|
} else {
|
||||||
let emitterObservable = fromEvent(emitterArg, eventArg);
|
const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg);
|
||||||
this.ObservableEmitterBundleObjectmap.add({
|
this.observableEmitterBundleArray.push({
|
||||||
observable: emitterObservable,
|
observable: emitterObservable,
|
||||||
emitter: emitterArg,
|
emitter: emitterArg,
|
||||||
event: eventArg
|
event: eventArg,
|
||||||
});
|
});
|
||||||
return emitterObservable;
|
return emitterObservable;
|
||||||
}
|
}
|
||||||
|
13
ts/smartrx.plugins.rxjs.ts
Normal file
13
ts/smartrx.plugins.rxjs.ts
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
// this file is intended to keep the bundle size down
|
||||||
|
|
||||||
|
export { Observable, Subject, fromEvent, ReplaySubject, Subscription, Observer } from 'rxjs';
|
||||||
|
|
||||||
|
import { startWith, takeUntil, map, debounce, debounceTime } from 'rxjs/operators';
|
||||||
|
|
||||||
|
export const ops = {
|
||||||
|
debounce,
|
||||||
|
debounceTime,
|
||||||
|
map,
|
||||||
|
startWith,
|
||||||
|
takeUntil,
|
||||||
|
};
|
@ -1,7 +1,3 @@
|
|||||||
import * as events from 'events';
|
|
||||||
import * as lik from '@pushrocks/lik';
|
|
||||||
import * as rxjs from 'rxjs';
|
|
||||||
import * as smartevent from 'smartevent';
|
|
||||||
import * as smartpromise from '@pushrocks/smartpromise';
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
|
|
||||||
export { events, lik, rxjs, smartevent, smartpromise };
|
export { smartpromise };
|
||||||
|
16
tslint.json
16
tslint.json
@ -1,3 +1,17 @@
|
|||||||
{
|
{
|
||||||
"extends": "tslint-config-standard"
|
"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"
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user