network-services - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

dist/service_pool.js

@@ -68,8 +68,11 @@ "use strict";
         let mux;
-        if (stream.writableObjectMode) {
+        if (stream.writableObjectMode && stream.readableObjectMode) {
             mux = new object_mux_1.ObjectMux(stream);
         }
-        else {
+        else if (!stream.writableObjectMode && !stream.readableObjectMode) {
             mux = new buffer_mux_1.BufferMux(stream);
         }
+        else {
+            throw new errors_1.NotImplementedError("Unsupported stream.");
+        }
         stream.on('close', () => {
@@ -76,0 +79,0 @@ for (const [uuid, muxMap] of this.callRegistrar.entries()) {

dist/service.js

@@ -17,3 +17,3 @@ "use strict";
         if (Service.streams.has(stream)) {
-            throw new errors_1.InstantiationError(`The stream.Duplex instance has already been associated with a Service.`);
+            throw new errors_1.InstantiationError("The stream.Duplex instance has already been associated with a Service.");
         }
@@ -26,8 +26,11 @@ else {
         }
-        if (stream.writableObjectMode) {
+        else if (stream.writableObjectMode && stream.readableObjectMode) {
             this.mux = new object_mux_1.ObjectMux(stream, options);
         }
-        else {
+        else if (!stream.writableObjectMode && !stream.readableObjectMode) {
             this.mux = new buffer_mux_1.BufferMux(stream, options);
         }
+        else {
+            throw new errors_1.NotImplementedError("Unsupported stream.");
+        }
     }
@@ -34,0 +37,0 @@ createServiceApp(app, options) {

package.json

 {
   "name": "network-services",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "",
@@ -5,0 +5,0 @@ "main": "./dist/index.js",

No alert changes

Improved metrics

Total package byte prevSize

73105

increased by0.53%

Lines of code

1112

increased by0.54%

No dependency changes