@bettercorp/service-base-plugin-events-rabbitmq - npm Package Compare versions

Comparing version 2.1.20220615151903 to 2.1.20220615203957

lib/plugins/events-rabbitmq/events/emitStreamAndReceiveStream.js

@@ -321,2 +321,3 @@ "use strict";
             let pushingData = false;
+            let streamStarted = false;
             const pushData = () => {
@@ -367,5 +368,7 @@ if (pushingData)
                         self.uSelf.log.info("Stream no longer readable.");
-                        pushData();
+                        if (!streamStarted)
+                            pushData();
                         return;
                     }
+                    streamStarted = true;
                     if (!self.publishChannel.sendToQueue(streamRefId, readData, {
@@ -372,0 +375,0 @@ expiration: self.queueOpts.messageTtl,

package.json

@@ -1,1 +0,1 @@
-{"name":"@bettercorp/service-base-plugin-events-rabbitmq","license":"AGPL-3.0-only","repository":{"url":"https://gitlab.com/BetterCorp/public/service-base-plugin-events-rabbitmq"},"scripts":{"dev":"nodemon --config node_modules/@bettercorp/service-base/build/nodemon.json","start":"ts-node node_modules/@bettercorp/service-base/lib/index.js","build":"tsc","deploy":"npm publish","version":"node ./node_modules/@bettercorp/service-base/build/version-bcorp.js $0","create":"ts-node node_modules/@bettercorp/service-base/lib/bootstrap.js $0","_test":"./node_modules/mocha/bin/mocha --reporter mocha-junit-reporter --reporter-options mochaFile=junit.xml","_testDev":"./node_modules/mocha/bin/mocha"},"files":["lib/**/*"],"main":"lib/index.js","version":"2.1.20220615151903","bsb_project":true,"devDependencies":{"@typescript-eslint/eslint-plugin":"^5.28.0","@typescript-eslint/parser":"^5.28.0","eslint":"^8.17.0","mocha":"^10.0.0","mocha-junit-reporter":"^2.0.2","ts-node":"^10.8.1","typescript":"^4.7.3"},"dependencies":{"@bettercorp/service-base":"^7.6.20220531162851","@bettercorp/tools":"^2.0.20220613145514","@types/amqplib":"^0.8.2","@types/node":"^17.0.44","amqplib":"^0.10.0"}}
+{"name":"@bettercorp/service-base-plugin-events-rabbitmq","license":"AGPL-3.0-only","repository":{"url":"https://gitlab.com/BetterCorp/public/service-base-plugin-events-rabbitmq"},"scripts":{"dev":"nodemon --config node_modules/@bettercorp/service-base/build/nodemon.json","start":"ts-node node_modules/@bettercorp/service-base/lib/index.js","build":"tsc","deploy":"npm publish","version":"node ./node_modules/@bettercorp/service-base/build/version-bcorp.js $0","create":"ts-node node_modules/@bettercorp/service-base/lib/bootstrap.js $0","_test":"./node_modules/mocha/bin/mocha --reporter mocha-junit-reporter --reporter-options mochaFile=junit.xml","_testDev":"./node_modules/mocha/bin/mocha"},"files":["lib/**/*"],"main":"lib/index.js","version":"2.1.20220615203957","bsb_project":true,"devDependencies":{"@typescript-eslint/eslint-plugin":"^5.28.0","@typescript-eslint/parser":"^5.28.0","eslint":"^8.17.0","mocha":"^10.0.0","mocha-junit-reporter":"^2.0.2","ts-node":"^10.8.1","typescript":"^4.7.3"},"dependencies":{"@bettercorp/service-base":"^7.6.20220531162851","@bettercorp/tools":"^2.0.20220613145514","@types/amqplib":"^0.8.2","@types/node":"^17.0.44","amqplib":"^0.10.0"}}

No alert changes

Improved metrics

Total package byte prevSize

106793

increased by0.2%

Lines of code

855

increased by0.35%

No dependency changes