Merge pull request #64 from onixjs/development

Release 1.0.0-beta.5.2
onixjs · Jul 21, 2018 · a704072 · a704072
2 parents a0a63eb + 19f3150
commit a704072
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@onixjs/core",
-  "version": "1.0.0-beta.5.1",
+  "version": "1.0.0-beta.5.2",
   "description": "An Enterprise Grade NodeJS Platform that implements Industry Standards and Patterns in order to provide Connectivity, Stability, High-Availability and High-Performance.",
   "main": "dist/src/index.js",
   "scripts": {
@@ -49,7 +49,7 @@
   },
   "dependencies": {
     "@onixjs/enumerable": "1.0.0-alpha.7",
-    "@onixjs/sdk": "^1.0.0-beta.4",
+    "@onixjs/sdk": "^1.0.0-beta.5",
     "finalhandler": "^1.1.1",
     "reflect-metadata": "^0.1.12",
     "router": "^1.3.2"

diff --git a/src/core/host.broker.ts b/src/core/host.broker.ts
@@ -132,8 +132,9 @@ export class HostBroker {
       // Verify the client is actually registered in this onixjs host
       this.registers[operation.message.request.metadata.register] &&
       // Also make sure this is a RPC or STREAM Unsubscription calls
-      (OperationType.ONIX_REMOTE_CALL_PROCEDURE ||
-        OperationType.ONIX_REMOTE_CALL_STREAM_UNSUBSCRIBE)
+      (operation.type === OperationType.ONIX_REMOTE_CALL_PROCEDURE ||
+        operation.type === OperationType.ONIX_REMOTE_CALL_STREAM ||
+        operation.type === OperationType.ONIX_REMOTE_CALL_STREAM_UNSUBSCRIBE)
     ) {
       // Add a new listener for this client subscription stream
       const index: number = this.registers[

diff --git a/src/index.ts b/src/index.ts
@@ -34,7 +34,7 @@ export class OnixJS {
    * @description Current Onix Version.
    */
   get version(): string {
-    return '1.0.0-beta.5.1';
+    return '1.0.0-beta.5.2';
   }
   /**
    * @property router