Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 71edd16d65 | |||
| f572603e04 | |||
| 71a1cde491 | |||
| 487cd53c3b | |||
| e050031313 | |||
| cbbb31e0e7 | |||
| a758196705 | |||
| 951d260103 | |||
| 9605721f75 | |||
| fe484e334f | |||
| 76a2ce1a9d | |||
| b4d9059f4f |
19
.gitignore
vendored
19
.gitignore
vendored
@ -1,5 +1,22 @@
|
||||
.nogit/
|
||||
node_modules/
|
||||
|
||||
# artifacts
|
||||
coverage/
|
||||
public/
|
||||
pages/
|
||||
|
||||
# installs
|
||||
node_modules/
|
||||
|
||||
# caches
|
||||
.yarn/
|
||||
.cache/
|
||||
.rpt2_cache
|
||||
|
||||
# builds
|
||||
dist/
|
||||
dist_web/
|
||||
dist_serve/
|
||||
dist_ts_web/
|
||||
|
||||
# custom
|
||||
@ -1,86 +1,119 @@
|
||||
# gitzone standard
|
||||
image: hosttoday/ht-docker-node:npmci
|
||||
# gitzone ci_default
|
||||
image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
|
||||
|
||||
cache:
|
||||
paths:
|
||||
- .yarn/
|
||||
- .npmci_cache/
|
||||
key: "$CI_BUILD_STAGE"
|
||||
|
||||
stages:
|
||||
- mirror
|
||||
- security
|
||||
- test
|
||||
- release
|
||||
- trigger
|
||||
- pages
|
||||
- metadata
|
||||
|
||||
# ====================
|
||||
# security stage
|
||||
# ====================
|
||||
mirror:
|
||||
stage: mirror
|
||||
stage: security
|
||||
script:
|
||||
- npmci git mirror
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
|
||||
testLEGACY:
|
||||
stage: test
|
||||
snyk:
|
||||
stage: security
|
||||
script:
|
||||
- npmci node install legacy
|
||||
- npmci npm install
|
||||
- npmci npm test
|
||||
coverage: /\d+.?\d+?\%\s*coverage/
|
||||
- npmci npm prepare
|
||||
- npmci command npm install -g snyk
|
||||
- npmci command npm install --ignore-scripts
|
||||
- npmci command snyk test
|
||||
tags:
|
||||
- docker
|
||||
allow_failure: true
|
||||
- notpriv
|
||||
|
||||
testLTS:
|
||||
stage: test
|
||||
script:
|
||||
- npmci node install lts
|
||||
- npmci npm install
|
||||
- npmci npm test
|
||||
coverage: /\d+.?\d+?\%\s*coverage/
|
||||
tags:
|
||||
- docker
|
||||
|
||||
testSTABLE:
|
||||
# ====================
|
||||
# test stage
|
||||
# ====================
|
||||
|
||||
testStable:
|
||||
stage: test
|
||||
script:
|
||||
- npmci npm prepare
|
||||
- npmci node install stable
|
||||
- npmci npm install
|
||||
- npmci npm test
|
||||
coverage: /\d+.?\d+?\%\s*coverage/
|
||||
tags:
|
||||
- docker
|
||||
- priv
|
||||
|
||||
testBuild:
|
||||
stage: test
|
||||
script:
|
||||
- npmci npm prepare
|
||||
- npmci node install lts
|
||||
- npmci npm install
|
||||
- npmci command npm run build
|
||||
coverage: /\d+.?\d+?\%\s*coverage/
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
|
||||
release:
|
||||
stage: release
|
||||
script:
|
||||
- npmci npm prepare
|
||||
- npmci node install lts
|
||||
- npmci npm publish
|
||||
only:
|
||||
- tags
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
|
||||
# ====================
|
||||
# metadata stage
|
||||
# ====================
|
||||
codequality:
|
||||
stage: metadata
|
||||
allow_failure: true
|
||||
script:
|
||||
- npmci command npm install -g tslint typescript
|
||||
- npmci npm install
|
||||
- npmci command "tslint -c tslint.json ./ts/**/*.ts"
|
||||
tags:
|
||||
- docker
|
||||
- priv
|
||||
|
||||
trigger:
|
||||
stage: trigger
|
||||
stage: metadata
|
||||
script:
|
||||
- npmci trigger
|
||||
only:
|
||||
- tags
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
|
||||
pages:
|
||||
image: hosttoday/ht-docker-node:npmci
|
||||
stage: pages
|
||||
image: hosttoday/ht-docker-dbase:npmci
|
||||
services:
|
||||
- docker:stable-dind
|
||||
stage: metadata
|
||||
script:
|
||||
- npmci command yarn global add npmpage
|
||||
- npmci command npmpage
|
||||
- npmci command npm install -g @gitzone/tsdoc
|
||||
- npmci npm prepare
|
||||
- npmci npm install
|
||||
- npmci command tsdoc
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
only:
|
||||
- tags
|
||||
artifacts:
|
||||
expire_in: 1 week
|
||||
paths:
|
||||
- public
|
||||
allow_failure: true
|
||||
|
||||
@ -1,4 +0,0 @@
|
||||
module.name: smartmodule
|
||||
module.description: a smart description
|
||||
module.author: Lossless GmbH
|
||||
module.license: MIT
|
||||
@ -1,13 +1,16 @@
|
||||
# smartrx
|
||||
|
||||
smart wrapper for rxjs
|
||||
|
||||
## Availabililty
|
||||
|
||||
[](https://www.npmjs.com/package/smartrx)
|
||||
[](https://GitLab.com/pushrocks/smartrx)
|
||||
[](https://github.com/pushrocks/smartrx)
|
||||
[](https://pushrocks.gitlab.io/smartrx/)
|
||||
|
||||
## Status for master
|
||||
|
||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://www.npmjs.com/package/smartrx)
|
||||
@ -19,11 +22,12 @@ smart wrapper for rxjs
|
||||
[](http://standardjs.com/)
|
||||
|
||||
## Usage
|
||||
|
||||
Use TypeScript for best in class instellisense.
|
||||
|
||||
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.html)
|
||||
|
||||
[](https://push.rocks)
|
||||
|
||||
@ -5,4 +5,4 @@ Observables have a smaller footprint and a more manageable subscribe logic.
|
||||
Observablemap registers only one rxjs observable per event and then continues to reference
|
||||
the same observable that you can subscribe to.
|
||||
|
||||
For further information read the linked docs at the top of this README.
|
||||
For further information read the linked docs at the top of this README.
|
||||
|
||||
@ -1,15 +1,19 @@
|
||||
{
|
||||
"npmci": {
|
||||
"npmGlobalTools": [
|
||||
"npmts"
|
||||
]
|
||||
"npmGlobalTools": [],
|
||||
"npmAccessLevel": "public"
|
||||
},
|
||||
"npmdocker": {
|
||||
"command": "rm -r node_modules && yarn install && yarn test"
|
||||
},
|
||||
"npmts": {
|
||||
"testConfig": {
|
||||
"parallel": false
|
||||
"gitzone": {
|
||||
"module": {
|
||||
"githost": "gitlab.com",
|
||||
"gitscope": "pushrocks",
|
||||
"gitrepo": "smartrx",
|
||||
"shortDescription": "smart wrapper for rxjs",
|
||||
"npmPackagename": "@pushrocks/smartrx",
|
||||
"license": "MIT"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
1678
package-lock.json
generated
Normal file
1678
package-lock.json
generated
Normal file
File diff suppressed because it is too large
Load Diff
38
package.json
38
package.json
@ -1,22 +1,40 @@
|
||||
{
|
||||
"name": "smartrx",
|
||||
"version": "1.0.5",
|
||||
"name": "@pushrocks/smartrx",
|
||||
"version": "2.0.5",
|
||||
"private": false,
|
||||
"description": "smart wrapper for rxjs",
|
||||
"main": "dist/index.js",
|
||||
"typings": "dist/index.d.ts",
|
||||
"author": "Lossless GmbH",
|
||||
"license": "MIT",
|
||||
"scripts": {
|
||||
"test": "(npmts)"
|
||||
"test": "(tstest test/)",
|
||||
"build": "(tsbuild)"
|
||||
},
|
||||
"devDependencies": {
|
||||
"tapbundle": "^1.1.8"
|
||||
"@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"
|
||||
},
|
||||
"dependencies": {
|
||||
"lik": "^2.0.1",
|
||||
"rxjs": "^5.5.2",
|
||||
"smartevent": "^1.0.1",
|
||||
"smartq": "^1.1.6",
|
||||
"typings-global": "^1.0.23"
|
||||
}
|
||||
"@pushrocks/lik": "^3.0.11",
|
||||
"@pushrocks/smartevent": "^2.0.3",
|
||||
"@pushrocks/smartpromise": "^3.0.2",
|
||||
"rxjs": "^6.5.3"
|
||||
},
|
||||
"files": [
|
||||
"ts/*",
|
||||
"ts_web/*",
|
||||
"dist/*",
|
||||
"dist_web/*",
|
||||
"dist_ts_web/*",
|
||||
"assets/*",
|
||||
"cli.js",
|
||||
"npmextra.json",
|
||||
"readme.md"
|
||||
]
|
||||
}
|
||||
|
||||
38
readme.md
38
readme.md
@ -1,29 +1,35 @@
|
||||
# smartrx
|
||||
# @pushrocks/smartrx
|
||||
smart wrapper for rxjs
|
||||
|
||||
## Availabililty
|
||||
[](https://www.npmjs.com/package/smartrx)
|
||||
[](https://GitLab.com/pushrocks/smartrx)
|
||||
[](https://github.com/pushrocks/smartrx)
|
||||
[](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
|
||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://GitLab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://www.npmjs.com/package/smartrx)
|
||||
[](https://david-dm.org/pushrocks/smartrx)
|
||||
[](https://www.bithound.io/github/pushrocks/smartrx/master/dependencies/npm)
|
||||
[](https://www.bithound.io/github/pushrocks/smartrx)
|
||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||
[](http://standardjs.com/)
|
||||
[](https://gitlab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://gitlab.com/pushrocks/smartrx/commits/master)
|
||||
[](https://www.npmjs.com/package/@pushrocks/smartrx)
|
||||
[](https://snyk.io/test/npm/@pushrocks/smartrx)
|
||||
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||
[](https://nodejs.org/dist/latest-v10.x/docs/api/)
|
||||
[](https://prettier.io/)
|
||||
|
||||
## Usage
|
||||
|
||||
Use TypeScript for best in class instellisense.
|
||||
|
||||
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.html)
|
||||
|
||||
[](https://push.rocks)
|
||||
|
||||
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)
|
||||
|
||||
[](https://maintainedby.lossless.com)
|
||||
|
||||
@ -1,40 +1,38 @@
|
||||
import { tap, expect } from 'tapbundle'
|
||||
import { tap, expect } from '@pushrocks/tapbundle';
|
||||
|
||||
import * as smartrx from '../ts/index'
|
||||
import * as smartrx from '../ts/index';
|
||||
|
||||
tap.test('should create a valid instance of observableinstake', async () => {
|
||||
const testObservableIntake = new smartrx.ObservableIntake()
|
||||
expect(testObservableIntake).to.be.instanceOf(smartrx.ObservableIntake)
|
||||
})
|
||||
const testObservableIntake = new smartrx.ObservableIntake();
|
||||
expect(testObservableIntake).to.be.instanceOf(smartrx.ObservableIntake);
|
||||
});
|
||||
|
||||
tap.test('expect testObserservableIntake to push things', async (tools) => {
|
||||
const testObserservableIntake = new smartrx.ObservableIntake()
|
||||
tap.test('expect testObserservableIntake to push things', async tools => {
|
||||
const testObserservableIntake = new smartrx.ObservableIntake();
|
||||
testObserservableIntake.subscribe(value => {
|
||||
console.log(value)
|
||||
})
|
||||
console.log(value);
|
||||
});
|
||||
|
||||
testObserservableIntake.push('hi')
|
||||
testObserservableIntake.push('wow')
|
||||
testObserservableIntake.signalComplete()
|
||||
await testObserservableIntake.completed
|
||||
})
|
||||
testObserservableIntake.push('hi');
|
||||
testObserservableIntake.push('wow');
|
||||
testObserservableIntake.signalComplete();
|
||||
await testObserservableIntake.completed;
|
||||
});
|
||||
|
||||
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')
|
||||
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 => {
|
||||
console.log(value)
|
||||
testObserservableIntake.signalComplete()
|
||||
})
|
||||
testObserservableIntake.request(1)
|
||||
await testObserservableIntake.completed
|
||||
})
|
||||
console.log(value);
|
||||
testObserservableIntake.signalComplete();
|
||||
});
|
||||
testObserservableIntake.request(1);
|
||||
await testObserservableIntake.completed;
|
||||
});
|
||||
|
||||
tap.test('', async () => {
|
||||
tap.test('', async () => {});
|
||||
|
||||
})
|
||||
|
||||
tap.start()
|
||||
tap.start();
|
||||
|
||||
@ -1,36 +1,36 @@
|
||||
// import test framework
|
||||
import { expect, tap } from 'tapbundle'
|
||||
import * as events from 'events'
|
||||
import * as rx from 'rxjs/Rx'
|
||||
import * as smartq from 'smartq'
|
||||
import { expect, tap } from '@pushrocks/tapbundle';
|
||||
import * as events from 'events';
|
||||
import * as rx from 'rxjs';
|
||||
import * as smartpromise from '@pushrocks/smartpromise';
|
||||
|
||||
// import the module
|
||||
import * as smartrx from '../ts/index'
|
||||
import * as smartrx from '../ts/index';
|
||||
|
||||
let testObservablemap: smartrx.Observablemap
|
||||
let testObservable1: rx.Observable<any>
|
||||
let testObservable2: rx.Observable<any>
|
||||
let testObservable3: rx.Observable<any>
|
||||
let testEmitter: events.EventEmitter
|
||||
let testObservablemap: smartrx.Observablemap;
|
||||
let testObservable1: rx.Observable<any>;
|
||||
let testObservable2: rx.Observable<any>;
|
||||
let testObservable3: rx.Observable<any>;
|
||||
let testEmitter: events.EventEmitter;
|
||||
|
||||
tap.test('should create an instance', async () => {
|
||||
testObservablemap = new smartrx.Observablemap()
|
||||
expect(testObservablemap).be.instanceof(smartrx.Observablemap)
|
||||
})
|
||||
testObservablemap = new smartrx.Observablemap();
|
||||
expect(testObservablemap).be.instanceof(smartrx.Observablemap);
|
||||
});
|
||||
|
||||
tap.test('should accept a new emitter', async () => {
|
||||
let done = smartq.defer()
|
||||
testEmitter = new events.EventEmitter()
|
||||
testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1')
|
||||
let done = smartpromise.defer();
|
||||
testEmitter = new events.EventEmitter();
|
||||
testObservable1 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
||||
testObservable1.subscribe(x => {
|
||||
done.resolve()
|
||||
})
|
||||
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1')
|
||||
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2')
|
||||
expect(testObservable1 === testObservable2).be.true()
|
||||
expect(testObservable1 === testObservable3).be.false()
|
||||
testEmitter.emit('event1')
|
||||
await done.promise
|
||||
})
|
||||
done.resolve();
|
||||
});
|
||||
testObservable2 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event1');
|
||||
testObservable3 = testObservablemap.getObservableForEmitterEvent(testEmitter, 'event2');
|
||||
expect(testObservable1 === testObservable2).to.be.true;
|
||||
expect(testObservable1 === testObservable3).to.be.false;
|
||||
testEmitter.emit('event1');
|
||||
await done.promise;
|
||||
});
|
||||
|
||||
tap.start()
|
||||
tap.start();
|
||||
|
||||
14
ts/index.ts
14
ts/index.ts
@ -1,11 +1,7 @@
|
||||
import * as plugins from './smartrx.plugins'
|
||||
import * as plugins from './smartrx.plugins';
|
||||
export * from './smartrx.classes.observablemap';
|
||||
export * from './smartrx.classes.observableintake';
|
||||
|
||||
export let standardExport = 'Hi there! :) This is a exported string'
|
||||
export * from './smartrx.classes.observablemap'
|
||||
export * from './smartrx.classes.observableintake'
|
||||
import * as rxjs from 'rxjs';
|
||||
|
||||
import * as rxjs from 'rxjs'
|
||||
|
||||
export {
|
||||
rxjs
|
||||
}
|
||||
export { rxjs };
|
||||
|
||||
@ -1,49 +1,49 @@
|
||||
import * as plugins from './smartrx.plugins'
|
||||
import { Observable, Subscription } from 'rxjs'
|
||||
import { Deferred } from 'smartq'
|
||||
import * as plugins from './smartrx.plugins';
|
||||
import { Observable, Subscription } from 'rxjs';
|
||||
import { Deferred } from '@pushrocks/smartpromise';
|
||||
|
||||
/**
|
||||
* ObservableIntake
|
||||
*/
|
||||
export class ObservableIntake<T> {
|
||||
observable: Observable<T>
|
||||
completed: Promise<void>
|
||||
private completedDeffered: Deferred<void>
|
||||
public observable: Observable<T>;
|
||||
public completed: Promise<void>;
|
||||
private completedDeffered: Deferred<void>;
|
||||
private observableFunctions: any = {
|
||||
next: (payloadArg) => {
|
||||
next: payloadArg => {
|
||||
// nothing
|
||||
},
|
||||
complete: (payloadArg) => {
|
||||
complete: payloadArg => {
|
||||
// nothing
|
||||
}
|
||||
}
|
||||
private generator = null
|
||||
private buffered = false
|
||||
private payloadBuffer = []
|
||||
};
|
||||
private generator = null;
|
||||
private buffered = false;
|
||||
private payloadBuffer = [];
|
||||
|
||||
constructor () {
|
||||
this.observable = Observable.create((observerArg) => {
|
||||
constructor() {
|
||||
this.observable = Observable.create(observerArg => {
|
||||
this.observableFunctions.next = (...args) => {
|
||||
return observerArg.next(...args)
|
||||
}
|
||||
return observerArg.next(...args);
|
||||
};
|
||||
this.observableFunctions.complete = (...args) => {
|
||||
this.completedDeffered.resolve()
|
||||
return observerArg.complete(...args)
|
||||
}
|
||||
})
|
||||
this.completedDeffered = plugins.smartq.defer()
|
||||
this.completed = this.completedDeffered.promise
|
||||
this.completedDeffered.resolve();
|
||||
return observerArg.complete(...args);
|
||||
};
|
||||
});
|
||||
this.completedDeffered = plugins.smartpromise.defer();
|
||||
this.completed = this.completedDeffered.promise;
|
||||
}
|
||||
|
||||
setObservable (observableFunc) {
|
||||
this.observable = observableFunc()
|
||||
public setObservable(observableFunc) {
|
||||
this.observable = observableFunc();
|
||||
}
|
||||
|
||||
push (payloadArg: T) {
|
||||
public push(payloadArg: T) {
|
||||
if (this.buffered) {
|
||||
this.payloadBuffer.push(payloadArg)
|
||||
this.payloadBuffer.push(payloadArg);
|
||||
} else {
|
||||
this.internalPush(payloadArg)
|
||||
this.internalPush(payloadArg);
|
||||
}
|
||||
}
|
||||
|
||||
@ -51,9 +51,9 @@ export class ObservableIntake<T> {
|
||||
* pushes many payloads as array
|
||||
* @param payloadArgArray
|
||||
*/
|
||||
pushMany (payloadArgArray: T[]) {
|
||||
for (let item of payloadArgArray) {
|
||||
this.push(item)
|
||||
public pushMany(payloadArgArray: T[]) {
|
||||
for (const item of payloadArgArray) {
|
||||
this.push(item);
|
||||
}
|
||||
}
|
||||
|
||||
@ -61,32 +61,32 @@ export class ObservableIntake<T> {
|
||||
* sets a generator to query the next pushed value
|
||||
* @param generatorArg
|
||||
*/
|
||||
setGenerator (generatorArg) {
|
||||
this.generator = generatorArg
|
||||
public setGenerator(generatorArg) {
|
||||
this.generator = generatorArg;
|
||||
}
|
||||
|
||||
makeBuffered() {
|
||||
this.buffered = true
|
||||
public makeBuffered() {
|
||||
this.buffered = true;
|
||||
}
|
||||
|
||||
subscribe (...args) {
|
||||
return this.observable.subscribe(...args)
|
||||
public subscribe(...args) {
|
||||
return this.observable.subscribe(...args);
|
||||
}
|
||||
|
||||
/**
|
||||
* request the next values in the quantity specified
|
||||
* @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) {
|
||||
return
|
||||
return;
|
||||
} else {
|
||||
for (let i = 0; i !== howManyArg; i++) {
|
||||
if (this.payloadBuffer.length > 0) {
|
||||
this.internalPush(this.payloadBuffer.shift())
|
||||
this.internalPush(this.payloadBuffer.shift());
|
||||
} else {
|
||||
const nextPayload = this.generator()
|
||||
this.internalPush(nextPayload)
|
||||
const nextPayload = this.generator();
|
||||
this.internalPush(nextPayload);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -95,11 +95,11 @@ export class ObservableIntake<T> {
|
||||
/**
|
||||
* signals the completion of this observable
|
||||
*/
|
||||
signalComplete () {
|
||||
this.observableFunctions.complete()
|
||||
public signalComplete() {
|
||||
this.observableFunctions.complete();
|
||||
}
|
||||
|
||||
private internalPush (payloadArg) {
|
||||
this.observableFunctions.next(payloadArg)
|
||||
private internalPush(payloadArg) {
|
||||
this.observableFunctions.next(payloadArg);
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,41 +1,39 @@
|
||||
import * as plugins from './smartrx.plugins'
|
||||
import { Observable } from 'rxjs'
|
||||
import { Objectmap } from 'lik'
|
||||
import { Stringmap } from 'lik'
|
||||
|
||||
import * as plugins from './smartrx.plugins';
|
||||
import { Observable, fromEvent } from 'rxjs';
|
||||
import { Objectmap, Stringmap } from '@pushrocks/lik';
|
||||
/**
|
||||
* bundles an observable with an emitter
|
||||
*/
|
||||
export interface ObservableEmitterBundle {
|
||||
observable: plugins.rxjs.Observable<any>
|
||||
emitter: plugins.events.EventEmitter
|
||||
event: string
|
||||
observable: plugins.rxjs.Observable<any>;
|
||||
emitter: plugins.events.EventEmitter;
|
||||
event: string;
|
||||
}
|
||||
|
||||
/**
|
||||
* manages observables by making sure that only one observable is regsitered per event
|
||||
*/
|
||||
export class Observablemap {
|
||||
ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>()
|
||||
ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>();
|
||||
|
||||
/**
|
||||
* creates a new observable if not yet registered for the same 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)
|
||||
})
|
||||
getObservableForEmitterEvent(emitterArg: plugins.events.EventEmitter, eventArg: string) {
|
||||
let existingBundle = this.ObservableEmitterBundleObjectmap.find(bundleArg => {
|
||||
return bundleArg.emitter === emitterArg && bundleArg.event === eventArg;
|
||||
});
|
||||
if (existingBundle) {
|
||||
return existingBundle.observable
|
||||
return existingBundle.observable;
|
||||
} else {
|
||||
let emitterObservable = plugins.rxjs.Observable.fromEvent(emitterArg, eventArg)
|
||||
let emitterObservable = fromEvent(emitterArg, eventArg);
|
||||
this.ObservableEmitterBundleObjectmap.add({
|
||||
observable: emitterObservable,
|
||||
emitter: emitterArg,
|
||||
event: eventArg
|
||||
})
|
||||
return emitterObservable
|
||||
});
|
||||
return emitterObservable;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ -1,15 +1,7 @@
|
||||
import 'typings-global'
|
||||
import * as events from 'events'
|
||||
import * as lik from 'lik'
|
||||
import * as rxjs from 'rxjs'
|
||||
import * as smartevent from 'smartevent'
|
||||
import * as smartq from 'smartq'
|
||||
import 'typings-global'
|
||||
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';
|
||||
|
||||
export {
|
||||
events,
|
||||
lik,
|
||||
rxjs,
|
||||
smartevent,
|
||||
smartq
|
||||
}
|
||||
export { events, lik, rxjs, smartevent, 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"
|
||||
}
|
||||
|
||||
369
yarn.lock
369
yarn.lock
@ -1,369 +0,0 @@
|
||||
# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
|
||||
# yarn lockfile v1
|
||||
|
||||
|
||||
"@types/code@^4.0.3":
|
||||
version "4.0.3"
|
||||
resolved "https://registry.yarnpkg.com/@types/code/-/code-4.0.3.tgz#9c4de39f86eb3eba070146d2dab7dbc3f8eac35f"
|
||||
|
||||
"@types/glob@*":
|
||||
version "5.0.33"
|
||||
resolved "https://registry.yarnpkg.com/@types/glob/-/glob-5.0.33.tgz#3dff7c6ce09d65abe919c7961dc3dee016f36ad7"
|
||||
dependencies:
|
||||
"@types/minimatch" "*"
|
||||
"@types/node" "*"
|
||||
|
||||
"@types/lodash@^4.14.74":
|
||||
version "4.14.80"
|
||||
resolved "https://registry.yarnpkg.com/@types/lodash/-/lodash-4.14.80.tgz#a6b8b7900e6a7dcbc2e90d9b6dfbe3f6a7f69951"
|
||||
|
||||
"@types/minimatch@*", "@types/minimatch@3.x.x":
|
||||
version "3.0.1"
|
||||
resolved "https://registry.yarnpkg.com/@types/minimatch/-/minimatch-3.0.1.tgz#b683eb60be358304ef146f5775db4c0e3696a550"
|
||||
|
||||
"@types/node@*", "@types/node@^8.0.33":
|
||||
version "8.0.47"
|
||||
resolved "https://registry.yarnpkg.com/@types/node/-/node-8.0.47.tgz#968e596f91acd59069054558a00708c445ca30c2"
|
||||
|
||||
"@types/shelljs@^0.7.4":
|
||||
version "0.7.5"
|
||||
resolved "https://registry.yarnpkg.com/@types/shelljs/-/shelljs-0.7.5.tgz#5834fb7385d1137bd2be5842f2c278ac36a117f4"
|
||||
dependencies:
|
||||
"@types/glob" "*"
|
||||
"@types/node" "*"
|
||||
|
||||
"@types/which@^1.0.28":
|
||||
version "1.0.28"
|
||||
resolved "https://registry.yarnpkg.com/@types/which/-/which-1.0.28.tgz#016e387629b8817bed653fe32eab5d11279c8df6"
|
||||
|
||||
ansi-256-colors@^1.1.0:
|
||||
version "1.1.0"
|
||||
resolved "https://registry.yarnpkg.com/ansi-256-colors/-/ansi-256-colors-1.1.0.tgz#910de50efcc7c09e3d82f2f87abd6b700c18818a"
|
||||
|
||||
balanced-match@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/balanced-match/-/balanced-match-1.0.0.tgz#89b4d199ab2bee49de164ea02b89ce462d71b767"
|
||||
|
||||
beautycolor@^1.0.7:
|
||||
version "1.0.11"
|
||||
resolved "https://registry.yarnpkg.com/beautycolor/-/beautycolor-1.0.11.tgz#71c5568d5a7ed5c144d3a54f753ad1b08862aea5"
|
||||
dependencies:
|
||||
ansi-256-colors "^1.1.0"
|
||||
typings-global "^1.0.14"
|
||||
|
||||
bindings@^1.2.1:
|
||||
version "1.3.0"
|
||||
resolved "https://registry.yarnpkg.com/bindings/-/bindings-1.3.0.tgz#b346f6ecf6a95f5a815c5839fc7cdb22502f1ed7"
|
||||
|
||||
brace-expansion@^1.1.7:
|
||||
version "1.1.8"
|
||||
resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-1.1.8.tgz#c07b211c7c952ec1f8efd51a77ef0d1d3990a292"
|
||||
dependencies:
|
||||
balanced-match "^1.0.0"
|
||||
concat-map "0.0.1"
|
||||
|
||||
code@^5.1.0:
|
||||
version "5.1.0"
|
||||
resolved "https://registry.yarnpkg.com/code/-/code-5.1.0.tgz#205e4213536c3cf21b12194384901fadcd81bc1a"
|
||||
dependencies:
|
||||
hoek "4.x.x"
|
||||
|
||||
concat-map@0.0.1:
|
||||
version "0.0.1"
|
||||
resolved "https://registry.yarnpkg.com/concat-map/-/concat-map-0.0.1.tgz#d8a96bd77fd68df7793a73036a3ba0d5405d477b"
|
||||
|
||||
define-properties@^1.1.2:
|
||||
version "1.1.2"
|
||||
resolved "https://registry.yarnpkg.com/define-properties/-/define-properties-1.1.2.tgz#83a73f2fea569898fb737193c8f873caf6d45c94"
|
||||
dependencies:
|
||||
foreach "^2.0.5"
|
||||
object-keys "^1.0.8"
|
||||
|
||||
early@^2.1.1:
|
||||
version "2.1.1"
|
||||
resolved "https://registry.yarnpkg.com/early/-/early-2.1.1.tgz#841e23254ea5dc54d8afaeee82f5ab65c00ee23c"
|
||||
dependencies:
|
||||
beautycolor "^1.0.7"
|
||||
smartq "^1.1.1"
|
||||
typings-global "^1.0.16"
|
||||
|
||||
es-abstract@^1.5.1:
|
||||
version "1.9.0"
|
||||
resolved "https://registry.yarnpkg.com/es-abstract/-/es-abstract-1.9.0.tgz#690829a07cae36b222e7fd9b75c0d0573eb25227"
|
||||
dependencies:
|
||||
es-to-primitive "^1.1.1"
|
||||
function-bind "^1.1.1"
|
||||
has "^1.0.1"
|
||||
is-callable "^1.1.3"
|
||||
is-regex "^1.0.4"
|
||||
|
||||
es-to-primitive@^1.1.1:
|
||||
version "1.1.1"
|
||||
resolved "https://registry.yarnpkg.com/es-to-primitive/-/es-to-primitive-1.1.1.tgz#45355248a88979034b6792e19bb81f2b7975dd0d"
|
||||
dependencies:
|
||||
is-callable "^1.1.1"
|
||||
is-date-object "^1.0.1"
|
||||
is-symbol "^1.0.1"
|
||||
|
||||
es6-error@^4.0.2:
|
||||
version "4.0.2"
|
||||
resolved "https://registry.yarnpkg.com/es6-error/-/es6-error-4.0.2.tgz#eec5c726eacef51b7f6b73c20db6e1b13b069c98"
|
||||
|
||||
foreach@^2.0.5:
|
||||
version "2.0.5"
|
||||
resolved "https://registry.yarnpkg.com/foreach/-/foreach-2.0.5.tgz#0bee005018aeb260d0a3af3ae658dd0136ec1b99"
|
||||
|
||||
fs.realpath@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/fs.realpath/-/fs.realpath-1.0.0.tgz#1504ad2523158caa40db4a2787cb01411994ea4f"
|
||||
|
||||
function-bind@^1.0.2, function-bind@^1.1.1:
|
||||
version "1.1.1"
|
||||
resolved "https://registry.yarnpkg.com/function-bind/-/function-bind-1.1.1.tgz#a56899d3ea3c9bab874bb9773b7c5ede92f4895d"
|
||||
|
||||
glob@^7.0.0:
|
||||
version "7.1.2"
|
||||
resolved "https://registry.yarnpkg.com/glob/-/glob-7.1.2.tgz#c19c9df9a028702d678612384a6552404c636d15"
|
||||
dependencies:
|
||||
fs.realpath "^1.0.0"
|
||||
inflight "^1.0.4"
|
||||
inherits "2"
|
||||
minimatch "^3.0.4"
|
||||
once "^1.3.0"
|
||||
path-is-absolute "^1.0.0"
|
||||
|
||||
has@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/has/-/has-1.0.1.tgz#8461733f538b0837c9361e39a9ab9e9704dc2f28"
|
||||
dependencies:
|
||||
function-bind "^1.0.2"
|
||||
|
||||
hoek@4.x.x:
|
||||
version "4.2.0"
|
||||
resolved "https://registry.yarnpkg.com/hoek/-/hoek-4.2.0.tgz#72d9d0754f7fe25ca2d01ad8f8f9a9449a89526d"
|
||||
|
||||
inflight@^1.0.4:
|
||||
version "1.0.6"
|
||||
resolved "https://registry.yarnpkg.com/inflight/-/inflight-1.0.6.tgz#49bd6331d7d02d0c09bc910a1075ba8165b56df9"
|
||||
dependencies:
|
||||
once "^1.3.0"
|
||||
wrappy "1"
|
||||
|
||||
inherits@2:
|
||||
version "2.0.3"
|
||||
resolved "https://registry.yarnpkg.com/inherits/-/inherits-2.0.3.tgz#633c2c83e3da42a502f52466022480f4208261de"
|
||||
|
||||
interpret@^1.0.0:
|
||||
version "1.0.4"
|
||||
resolved "https://registry.yarnpkg.com/interpret/-/interpret-1.0.4.tgz#820cdd588b868ffb191a809506d6c9c8f212b1b0"
|
||||
|
||||
is-callable@^1.1.1, is-callable@^1.1.3:
|
||||
version "1.1.3"
|
||||
resolved "https://registry.yarnpkg.com/is-callable/-/is-callable-1.1.3.tgz#86eb75392805ddc33af71c92a0eedf74ee7604b2"
|
||||
|
||||
is-date-object@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/is-date-object/-/is-date-object-1.0.1.tgz#9aa20eb6aeebbff77fbd33e74ca01b33581d3a16"
|
||||
|
||||
is-regex@^1.0.4:
|
||||
version "1.0.4"
|
||||
resolved "https://registry.yarnpkg.com/is-regex/-/is-regex-1.0.4.tgz#5517489b547091b0930e095654ced25ee97e9491"
|
||||
dependencies:
|
||||
has "^1.0.1"
|
||||
|
||||
is-symbol@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/is-symbol/-/is-symbol-1.0.1.tgz#3cc59f00025194b6ab2e38dbae6689256b660572"
|
||||
|
||||
isexe@^2.0.0:
|
||||
version "2.0.0"
|
||||
resolved "https://registry.yarnpkg.com/isexe/-/isexe-2.0.0.tgz#e8fbf374dc556ff8947a10dcb0572d633f2cfa10"
|
||||
|
||||
leakage@^0.3.0:
|
||||
version "0.3.0"
|
||||
resolved "https://registry.yarnpkg.com/leakage/-/leakage-0.3.0.tgz#15d698abdc76bbc6439601f4f3020e77e2d50c39"
|
||||
dependencies:
|
||||
es6-error "^4.0.2"
|
||||
left-pad "^1.1.3"
|
||||
memwatch-next "^0.3.0"
|
||||
minimist "^1.2.0"
|
||||
pretty-bytes "^4.0.2"
|
||||
|
||||
left-pad@^1.1.3:
|
||||
version "1.1.3"
|
||||
resolved "https://registry.yarnpkg.com/left-pad/-/left-pad-1.1.3.tgz#612f61c033f3a9e08e939f1caebeea41b6f3199a"
|
||||
|
||||
lik@^2.0.1:
|
||||
version "2.0.1"
|
||||
resolved "https://registry.yarnpkg.com/lik/-/lik-2.0.1.tgz#828be73de3e356d12ee020d1499b9a99538cfa3d"
|
||||
dependencies:
|
||||
"@types/lodash" "^4.14.74"
|
||||
"@types/minimatch" "3.x.x"
|
||||
lodash "^4.17.4"
|
||||
minimatch "^3.0.4"
|
||||
smartq "^1.1.6"
|
||||
typings-global "^1.0.20"
|
||||
|
||||
lodash@^4.17.4:
|
||||
version "4.17.4"
|
||||
resolved "https://registry.yarnpkg.com/lodash/-/lodash-4.17.4.tgz#78203a4d1c328ae1d86dca6460e369b57f4055ae"
|
||||
|
||||
memwatch-next@^0.3.0:
|
||||
version "0.3.0"
|
||||
resolved "https://registry.yarnpkg.com/memwatch-next/-/memwatch-next-0.3.0.tgz#2111050f9a906e0aa2d72a4ec0f0089c78726f8f"
|
||||
dependencies:
|
||||
bindings "^1.2.1"
|
||||
nan "^2.3.2"
|
||||
|
||||
minimatch@^3.0.4:
|
||||
version "3.0.4"
|
||||
resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-3.0.4.tgz#5166e286457f03306064be5497e8dbb0c3d32083"
|
||||
dependencies:
|
||||
brace-expansion "^1.1.7"
|
||||
|
||||
minimist@^1.2.0:
|
||||
version "1.2.0"
|
||||
resolved "https://registry.yarnpkg.com/minimist/-/minimist-1.2.0.tgz#a35008b20f41383eec1fb914f4cd5df79a264284"
|
||||
|
||||
nan@^2.3.2:
|
||||
version "2.7.0"
|
||||
resolved "https://registry.yarnpkg.com/nan/-/nan-2.7.0.tgz#d95bf721ec877e08db276ed3fc6eb78f9083ad46"
|
||||
|
||||
object-keys@^1.0.8:
|
||||
version "1.0.11"
|
||||
resolved "https://registry.yarnpkg.com/object-keys/-/object-keys-1.0.11.tgz#c54601778ad560f1142ce0e01bcca8b56d13426d"
|
||||
|
||||
object.getownpropertydescriptors@^2.0.3:
|
||||
version "2.0.3"
|
||||
resolved "https://registry.yarnpkg.com/object.getownpropertydescriptors/-/object.getownpropertydescriptors-2.0.3.tgz#8758c846f5b407adab0f236e0986f14b051caa16"
|
||||
dependencies:
|
||||
define-properties "^1.1.2"
|
||||
es-abstract "^1.5.1"
|
||||
|
||||
once@^1.3.0:
|
||||
version "1.4.0"
|
||||
resolved "https://registry.yarnpkg.com/once/-/once-1.4.0.tgz#583b1aa775961d4b113ac17d9c50baef9dd76bd1"
|
||||
dependencies:
|
||||
wrappy "1"
|
||||
|
||||
path-is-absolute@^1.0.0:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/path-is-absolute/-/path-is-absolute-1.0.1.tgz#174b9268735534ffbc7ace6bf53a5a9e1b5c5f5f"
|
||||
|
||||
path-parse@^1.0.5:
|
||||
version "1.0.5"
|
||||
resolved "https://registry.yarnpkg.com/path-parse/-/path-parse-1.0.5.tgz#3c1adf871ea9cd6c9431b6ea2bd74a0ff055c4c1"
|
||||
|
||||
pretty-bytes@^4.0.2:
|
||||
version "4.0.2"
|
||||
resolved "https://registry.yarnpkg.com/pretty-bytes/-/pretty-bytes-4.0.2.tgz#b2bf82e7350d65c6c33aa95aaa5a4f6327f61cd9"
|
||||
|
||||
rechoir@^0.6.2:
|
||||
version "0.6.2"
|
||||
resolved "https://registry.yarnpkg.com/rechoir/-/rechoir-0.6.2.tgz#85204b54dba82d5742e28c96756ef43af50e3384"
|
||||
dependencies:
|
||||
resolve "^1.1.6"
|
||||
|
||||
resolve@^1.1.6:
|
||||
version "1.5.0"
|
||||
resolved "https://registry.yarnpkg.com/resolve/-/resolve-1.5.0.tgz#1f09acce796c9a762579f31b2c1cc4c3cddf9f36"
|
||||
dependencies:
|
||||
path-parse "^1.0.5"
|
||||
|
||||
rxjs@^5.5.2:
|
||||
version "5.5.2"
|
||||
resolved "https://registry.yarnpkg.com/rxjs/-/rxjs-5.5.2.tgz#28d403f0071121967f18ad665563255d54236ac3"
|
||||
dependencies:
|
||||
symbol-observable "^1.0.1"
|
||||
|
||||
semver@^5.3.0:
|
||||
version "5.4.1"
|
||||
resolved "https://registry.yarnpkg.com/semver/-/semver-5.4.1.tgz#e059c09d8571f0540823733433505d3a2f00b18e"
|
||||
|
||||
shelljs@^0.7.8:
|
||||
version "0.7.8"
|
||||
resolved "https://registry.yarnpkg.com/shelljs/-/shelljs-0.7.8.tgz#decbcf874b0d1e5fb72e14b164a9683048e9acb3"
|
||||
dependencies:
|
||||
glob "^7.0.0"
|
||||
interpret "^1.0.0"
|
||||
rechoir "^0.6.2"
|
||||
|
||||
smartchai@^1.0.3:
|
||||
version "1.0.8"
|
||||
resolved "https://registry.yarnpkg.com/smartchai/-/smartchai-1.0.8.tgz#a074836f4ddd4b98c50f1e7ae9e8e8ad9f6f1902"
|
||||
dependencies:
|
||||
"@types/code" "^4.0.3"
|
||||
code "^5.1.0"
|
||||
typings-global "^1.0.20"
|
||||
|
||||
smartdelay@^1.0.3:
|
||||
version "1.0.4"
|
||||
resolved "https://registry.yarnpkg.com/smartdelay/-/smartdelay-1.0.4.tgz#791c1a4ee6770494064c10b1d2d2b8e6f3105b82"
|
||||
dependencies:
|
||||
smartq "^1.1.1"
|
||||
typings-global "^1.0.16"
|
||||
|
||||
smartevent@^1.0.1:
|
||||
version "1.0.1"
|
||||
resolved "https://registry.yarnpkg.com/smartevent/-/smartevent-1.0.1.tgz#13d2bf2cf094ebdf17813fa0d46041f817a302aa"
|
||||
dependencies:
|
||||
smartq "^1.1.1"
|
||||
typings-global "^1.0.16"
|
||||
|
||||
smartq@^1.1.1, smartq@^1.1.6:
|
||||
version "1.1.6"
|
||||
resolved "https://registry.yarnpkg.com/smartq/-/smartq-1.1.6.tgz#0c1ff4336d95e95b4f1fdd8ccd7e2c5a323b8412"
|
||||
dependencies:
|
||||
typings-global "^1.0.19"
|
||||
util.promisify "^1.0.0"
|
||||
|
||||
smartshell@^1.0.6:
|
||||
version "1.0.18"
|
||||
resolved "https://registry.yarnpkg.com/smartshell/-/smartshell-1.0.18.tgz#b84ccc65cedf3a875bf676cec78ee07f4b4aa9e5"
|
||||
dependencies:
|
||||
"@types/shelljs" "^0.7.4"
|
||||
"@types/which" "^1.0.28"
|
||||
shelljs "^0.7.8"
|
||||
smartq "^1.1.6"
|
||||
typings-global "^1.0.20"
|
||||
which "^1.3.0"
|
||||
|
||||
symbol-observable@^1.0.1:
|
||||
version "1.0.4"
|
||||
resolved "https://registry.yarnpkg.com/symbol-observable/-/symbol-observable-1.0.4.tgz#29bf615d4aa7121bdd898b22d4b3f9bc4e2aa03d"
|
||||
|
||||
tapbundle@^1.1.8:
|
||||
version "1.1.8"
|
||||
resolved "https://registry.yarnpkg.com/tapbundle/-/tapbundle-1.1.8.tgz#e08aee0e100a830d8a26a583a85d37ce53312e02"
|
||||
dependencies:
|
||||
"@types/node" "^8.0.33"
|
||||
early "^2.1.1"
|
||||
leakage "^0.3.0"
|
||||
smartchai "^1.0.3"
|
||||
smartdelay "^1.0.3"
|
||||
smartq "^1.1.1"
|
||||
typings-global "^1.0.19"
|
||||
|
||||
typings-global@^1.0.14, typings-global@^1.0.16, typings-global@^1.0.19, typings-global@^1.0.20, typings-global@^1.0.23:
|
||||
version "1.0.23"
|
||||
resolved "https://registry.yarnpkg.com/typings-global/-/typings-global-1.0.23.tgz#cdd085803049dd07d95b2e1475243c6b2db378ab"
|
||||
dependencies:
|
||||
semver "^5.3.0"
|
||||
smartshell "^1.0.6"
|
||||
|
||||
util.promisify@^1.0.0:
|
||||
version "1.0.0"
|
||||
resolved "https://registry.yarnpkg.com/util.promisify/-/util.promisify-1.0.0.tgz#440f7165a459c9a16dc145eb8e72f35687097030"
|
||||
dependencies:
|
||||
define-properties "^1.1.2"
|
||||
object.getownpropertydescriptors "^2.0.3"
|
||||
|
||||
which@^1.3.0:
|
||||
version "1.3.0"
|
||||
resolved "https://registry.yarnpkg.com/which/-/which-1.3.0.tgz#ff04bdfc010ee547d780bec38e1ac1c2777d253a"
|
||||
dependencies:
|
||||
isexe "^2.0.0"
|
||||
|
||||
wrappy@1:
|
||||
version "1.0.2"
|
||||
resolved "https://registry.yarnpkg.com/wrappy/-/wrappy-1.0.2.tgz#b5243d8f3ec1aa35f1364605bc0d1036e30ab69f"
|
||||
Reference in New Issue
Block a user