1.0.27

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@pushrocks/smartchok",
-  "version": "1.0.26",
+  "version": "1.0.27",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "@pushrocks/smartchok",
-      "version": "1.0.26",
+      "version": "1.0.27",
       "license": "MIT",
       "dependencies": {
         "@pushrocks/lik": "^5.0.0",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartchok",
-  "version": "1.0.26",
+  "version": "1.0.27",
   "private": false,
   "description": "smart wrapper for chokidar",
   "main": "dist_ts/index.js",

test/test.ts

@@ -4,13 +4,15 @@ import * as smartfile from '@pushrocks/smartfile';
 import * as smartpromise from '@pushrocks/smartpromise';
 import * as smartrx from '@pushrocks/smartrx';
 
+import * as fs from 'fs';
+
 // the module to test
 if (process.env.CI) {
   process.exit(0);
 }
 
 let testSmartchok: smartchok.Smartchok;
-let testAddObservable: smartrx.rxjs.Observable<any>;
+let testAddObservable: smartrx.rxjs.Observable<[string, fs.Stats]>;
 let testSubscription: smartrx.rxjs.Subscription;
 tap.test('should create a new instance', async () => {
   testSmartchok = new smartchok.Smartchok([]);
@@ -31,7 +33,9 @@ tap.test('should get an observable for a certain event', async () => {
 
 tap.test('should register an add operation', async () => {
   let testDeferred = smartpromise.defer();
-  testSubscription = testAddObservable.subscribe((x) => {
+  testSubscription = testAddObservable.subscribe(pathArg => {
+    const pathResult = pathArg[0];
+    console.log(pathResult);
     testDeferred.resolve();
   });
   smartfile.memory.toFs('HI', './test/assets/hi.txt');

ts/smartchok.classes.smartchok.ts

@@ -49,7 +49,7 @@ export class Smartchok {
   /**
    * gets an observable for a certain event
    */
-  public getObservableFor(fsEvent: TFsEvent): Promise<plugins.smartrx.rxjs.Observable<any>> {
+  public getObservableFor(fsEvent: TFsEvent): Promise<plugins.smartrx.rxjs.Observable<[string, plugins.fs.Stats]>> {
     const done = plugins.smartpromise.defer<plugins.smartrx.rxjs.Observable<any>>();
     this.watchingDeferred.promise.then(() => {
       const eventObservable = this.eventObservablemap.getObservableForEmitterEvent(

ts/smartchok.plugins.ts

@@ -1,7 +1,9 @@
 // node native
+import * as fs from 'fs';
 import * as path from 'path';
 
 export {
+  fs,
   path
 }