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

fix Promise issues

Browse Source
This commit is contained in:
Philipp Kunz
2017-06-30 20:32:35 +02:00
parent af9eb0d99e
commit 7d4975cea8
8 changed files with 17 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ts/smartchok.classes.smartchok.ts
View File

@ -12,7 +12,7 @@ export class Smartchok {
chokidarOptions: plugins.chokidar.WatchOptions
status: TSmartchokStatus = 'idle'
private watcher
private watchingDeferred = plugins.q.defer<void>() // used to run things when watcher is initialized
private watchingDeferred = plugins.smartq.defer<void>() // used to run things when watcher is initialized
private eventObservablemap = new plugins.lik.Observablemap() // register one observable per event
/**
@ -40,8 +40,8 @@ export class Smartchok {
/**
* gets an observable for a certain event
*/
getObservableFor (fsEvent: TFsEvent): plugins.q.Promise<plugins.rx.Observable<any>> {
let done = plugins.q.defer<plugins.rx.Observable<any>>()
getObservableFor (fsEvent: TFsEvent): Promise<plugins.rx.Observable<any>> {
let done = plugins.smartq.defer<plugins.rx.Observable<any>>()
this.watchingDeferred.promise.then(() => {
let eventObservable = this.eventObservablemap.getObservableForEmitterEvent(this.watcher, fsEvent)
done.resolve(eventObservable)
@ -53,8 +53,8 @@ export class Smartchok {
* starts the watcher
* @returns Promise<void>
*/
start(): plugins.q.Promise<void> {
let done = plugins.q.defer<void>()
start(): Promise<void> {
let done = plugins.smartq.defer<void>()
this.status = 'starting'
this.watcher = plugins.chokidar.watch(this.watchStringmap.getStringArray(), this.chokidarOptions)
this.watcher.on('ready', () => {