Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
7168bd7ffd | |||
5031d28c32 | |||
4eaf91af3a | |||
511396894d |
4
package-lock.json
generated
4
package-lock.json
generated
@ -1,12 +1,12 @@
|
||||
{
|
||||
"name": "@pushrocks/smartrx",
|
||||
"version": "2.0.21",
|
||||
"version": "2.0.23",
|
||||
"lockfileVersion": 2,
|
||||
"requires": true,
|
||||
"packages": {
|
||||
"": {
|
||||
"name": "@pushrocks/smartrx",
|
||||
"version": "2.0.21",
|
||||
"version": "2.0.23",
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"@pushrocks/lik": "^5.0.1",
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@pushrocks/smartrx",
|
||||
"version": "2.0.21",
|
||||
"version": "2.0.23",
|
||||
"private": false,
|
||||
"description": "smart wrapper for rxjs",
|
||||
"main": "dist_ts/index.js",
|
||||
|
@ -1,6 +1,7 @@
|
||||
import * as plugins from './smartrx.plugins';
|
||||
export * from './smartrx.classes.observablemap';
|
||||
export * from './smartrx.classes.observableintake';
|
||||
|
||||
import * as rxjs from './smartrx.plugins.rxjs';
|
||||
export { rxjs };
|
||||
export {
|
||||
rxjs
|
||||
}
|
||||
|
@ -1,4 +1,5 @@
|
||||
import * as plugins from './smartrx.plugins';
|
||||
import * as rxjs from './smartrx.plugins.rxjs';
|
||||
|
||||
export interface IEventEmitter<T = any> {
|
||||
on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void;
|
||||
@ -8,7 +9,7 @@ export interface IEventEmitter<T = any> {
|
||||
* bundles an observable with an emitter
|
||||
*/
|
||||
export interface IObservableEmitterBundle {
|
||||
observable: plugins.rxjs.Observable<any>;
|
||||
observable: rxjs.Observable<any>;
|
||||
emitter: IEventEmitter<unknown>;
|
||||
event: string;
|
||||
}
|
||||
@ -30,7 +31,7 @@ export class Observablemap {
|
||||
if (existingBundle) {
|
||||
return existingBundle.observable;
|
||||
} else {
|
||||
const emitterObservable = plugins.rxjs.fromEvent<T>(emitterArg as any, eventArg);
|
||||
const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg);
|
||||
this.observableEmitterBundleObjectmap.add({
|
||||
observable: emitterObservable,
|
||||
emitter: emitterArg,
|
||||
|
@ -1,5 +1,4 @@
|
||||
import * as lik from '@pushrocks/lik';
|
||||
import * as rxjs from './smartrx.plugins.rxjs';
|
||||
import * as smartpromise from '@pushrocks/smartpromise';
|
||||
|
||||
export { lik, rxjs, smartpromise };
|
||||
export { lik, smartpromise };
|
||||
|
Reference in New Issue
Block a user