2.0.4

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartrx",
-  "version": "2.0.2",
+  "version": "2.0.4",
   "private": false,
   "description": "smart wrapper for rxjs",
   "main": "dist/index.js",
@@ -12,18 +12,18 @@
     "build": "(tsbuild)"
   },
   "devDependencies": {
-    "@gitzone/tsbuild": "^2.0.22",
-    "@gitzone/tsrun": "^1.1.13",
-    "@gitzone/tstest": "^1.0.15",
-    "@pushrocks/tapbundle": "^3.0.7",
-    "@types/node": "^10.12.10",
-    "tslint": "^5.11.0",
-    "tslint-config-prettier": "^1.16.0"
+    "@gitzone/tsbuild": "^2.1.17",
+    "@gitzone/tsrun": "^1.2.8",
+    "@gitzone/tstest": "^1.0.24",
+    "@pushrocks/tapbundle": "^3.0.13",
+    "@types/node": "^12.7.4",
+    "tslint": "^5.20.0",
+    "tslint-config-prettier": "^1.18.0"
   },
   "dependencies": {
-    "@pushrocks/lik": "^3.0.1",
-    "@pushrocks/smartpromise": "^2.0.5",
-    "rxjs": "^6.3.3",
-    "smartevent": "^1.0.1"
+    "@pushrocks/lik": "^3.0.11",
+    "@pushrocks/smartevent": "^2.0.3",
+    "@pushrocks/smartpromise": "^3.0.2",
+    "rxjs": "^6.5.3"
   }
 }

ts/index.ts

@@ -1,6 +1,4 @@
 import * as plugins from './smartrx.plugins';
-
-export let standardExport = 'Hi there! :) This is a exported string';
 export * from './smartrx.classes.observablemap';
 export * from './smartrx.classes.observableintake';
 

ts/smartrx.classes.observableintake.ts

@@ -1,13 +1,13 @@
 import * as plugins from './smartrx.plugins';
 import { Observable, Subscription } from 'rxjs';
-import { Deferred } from 'smartq';
+import { Deferred } from '@pushrocks/smartpromise';
 
 /**
  * ObservableIntake
  */
 export class ObservableIntake<T> {
-  observable: Observable<T>;
-  completed: Promise<void>;
+  public observable: Observable<T>;
+  public completed: Promise<void>;
   private completedDeffered: Deferred<void>;
   private observableFunctions: any = {
     next: payloadArg => {
@@ -35,11 +35,11 @@ export class ObservableIntake<T> {
     this.completed = this.completedDeffered.promise;
   }
 
-  setObservable(observableFunc) {
+  public setObservable(observableFunc) {
     this.observable = observableFunc();
   }
 
-  push(payloadArg: T) {
+  public push(payloadArg: T) {
     if (this.buffered) {
       this.payloadBuffer.push(payloadArg);
     } else {
@@ -51,8 +51,8 @@ export class ObservableIntake<T> {
    * pushes many payloads as array
    * @param payloadArgArray
    */
-  pushMany(payloadArgArray: T[]) {
-    for (let item of payloadArgArray) {
+  public pushMany(payloadArgArray: T[]) {
+    for (const item of payloadArgArray) {
       this.push(item);
     }
   }
@@ -61,15 +61,15 @@ export class ObservableIntake<T> {
    * sets a generator to query the next pushed value
    * @param generatorArg
    */
-  setGenerator(generatorArg) {
+  public setGenerator(generatorArg) {
     this.generator = generatorArg;
   }
 
-  makeBuffered() {
+  public makeBuffered() {
     this.buffered = true;
   }
 
-  subscribe(...args) {
+  public subscribe(...args) {
     return this.observable.subscribe(...args);
   }
 
@@ -77,7 +77,7 @@ export class ObservableIntake<T> {
    * request the next values in the quantity specified
    * @param howManyArg if a generator is set, of a buffer exists, this allows retrieving values
    */
-  request(howManyArg: number) {
+  public request(howManyArg: number) {
     if (howManyArg === 0) {
       return;
     } else {
@@ -95,7 +95,7 @@ export class ObservableIntake<T> {
   /**
    * signals the completion of this observable
    */
-  signalComplete() {
+  public signalComplete() {
     this.observableFunctions.complete();
   }
 

ts/smartrx.plugins.ts

@@ -1,7 +1,7 @@
 import * as events from 'events';
 import * as lik from '@pushrocks/lik';
 import * as rxjs from 'rxjs';
-import * as smartevent from 'smartevent';
+import * as smartevent from '@pushrocks/smartevent';
 import * as smartpromise from '@pushrocks/smartpromise';
 
 export { events, lik, rxjs, smartevent, smartpromise };