push.rocks/smartrx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2022-01-24 07:30:54 +01:00
parent 4eaf91af3a
commit 5031d28c32
3 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ts/index.ts
View File

@ -1,4 +1,7 @@
import * as plugins from './smartrx.plugins'; import * as plugins from './smartrx.plugins';
export * from './smartrx.classes.observablemap'; export * from './smartrx.classes.observablemap';
export * from './smartrx.classes.observableintake'; export * from './smartrx.classes.observableintake';
export * from './smartrx.plugins.rxjs'; import * as rxjs from './smartrx.plugins.rxjs';
export {
rxjs
}

5
ts/smartrx.classes.observablemap.ts
View File

@ -1,4 +1,5 @@
import * as plugins from './smartrx.plugins'; import * as plugins from './smartrx.plugins';
import * as rxjs from './smartrx.plugins.rxjs';
export interface IEventEmitter<T = any> { export interface IEventEmitter<T = any> {
on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void; on: (eventNameArg: string, eventHandlerArg: (eventPayload: T) => any) => void;
@ -8,7 +9,7 @@ export interface IEventEmitter<T = any> {
* bundles an observable with an emitter * bundles an observable with an emitter
*/ */
export interface IObservableEmitterBundle { export interface IObservableEmitterBundle {
observable: plugins.rxjs.Observable<any>; observable: rxjs.Observable<any>;
emitter: IEventEmitter<unknown>; emitter: IEventEmitter<unknown>;
event: string; event: string;
} }
@ -30,7 +31,7 @@ export class Observablemap {
if (existingBundle) { if (existingBundle) {
return existingBundle.observable; return existingBundle.observable;
} else { } else {
const emitterObservable = plugins.rxjs.fromEvent<T>(emitterArg as any, eventArg); const emitterObservable = rxjs.fromEvent<T>(emitterArg as any, eventArg);
this.observableEmitterBundleObjectmap.add({ this.observableEmitterBundleObjectmap.add({
observable: emitterObservable, observable: emitterObservable,
emitter: emitterArg, emitter: emitterArg,

3
ts/smartrx.plugins.ts
View File

@ -1,5 +1,4 @@
import * as lik from '@pushrocks/lik'; import * as lik from '@pushrocks/lik';
import * as rxjs from './smartrx.plugins.rxjs';
import * as smartpromise from '@pushrocks/smartpromise'; import * as smartpromise from '@pushrocks/smartpromise';
export { lik, rxjs, smartpromise }; export { lik, smartpromise };