36 lines
1.2 KiB
TypeScript
36 lines
1.2 KiB
TypeScript
import * as plugins from './lik.plugins'
|
|
import { Objectmap } from './lik.objectmap'
|
|
import { Stringmap } from './lik.stringmap'
|
|
import { Observable } from 'rxjs/Rx'
|
|
|
|
|
|
/**
|
|
* bundles an observable with an emitter
|
|
*/
|
|
export interface ObservableEmitterBundle {
|
|
observable: plugins.rx.Observable<any>
|
|
emitter: plugins.events.EventEmitter
|
|
event: string
|
|
}
|
|
|
|
export class Observablemap {
|
|
ObservableEmitterBundleObjectmap = new Objectmap<ObservableEmitterBundle>()
|
|
|
|
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
|
|
} else {
|
|
let emitterObservable = plugins.rx.Observable.fromEvent(emitterArg, eventArg)
|
|
this.ObservableEmitterBundleObjectmap.add({
|
|
observable: emitterObservable,
|
|
emitter: emitterArg,
|
|
event: eventArg
|
|
})
|
|
return emitterObservable
|
|
}
|
|
}
|
|
}
|