rxprotoplex - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

lib/connectAndSend.js

@@ -23,5 +23,8 @@ import {plexIdConfigOrganizeArguments} from "./plexIdConfigOrganizeArguments.js";
     if (config.encoding) config.encoding = encodingFrom(config.encoding);
-    return data => asPlex(plex).connect(id, config).end(data);
+    return data => {
+        if (data?.data && data.id && data.stream && data.protocol) data = data.data;
+        return asPlex(plex).connect(id, config).end(data);
+    };
 });
 
 export const sendOnce = connectAndSend;

lib/tapSend.js

@@ -25,3 +25,6 @@ import {plexIdConfigOrganizeArguments} from "./plexIdConfigOrganizeArguments.js";
     const sender = connectAndSend(plex, id, config);
-    return tap(result => sender(result));
+    return tap(data => {
+        if (data?.data && data.id && data.stream && data.protocol) data = data.data;
+        return sender(data);
+    });
 });

package.json

 {
   "name": "rxprotoplex",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "A utility library for working with Plex-based connections and streams with RxJS operators.",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

33323

increased by0.65%

Lines of code

619

increased by0.98%

No dependency changes