[question] How to make the message streams work for inter process communication. about shared-memory-disruptor

[davedoesdev]

@falcon027 congrats, you found a bug!

I have a fix:

diff --git a/lib/disruptor.js b/lib/disruptor.js
index 92c497c..7bc4418 100644
--- a/lib/disruptor.js
+++ b/lib/disruptor.js
@@ -267,7 +267,7 @@ class DisruptorWriteStream extends Writable {
         }
         let i = 0;
         for (const buf of bufs) {
-            chunk.copy(buf, 0, i, buf.length);
+            chunk.copy(buf, 0, i, i + buf.length);
             i += buf.length;
         }
         if (i === 0) {

I'll publish it soon but I want to get your example into the tests first.

[davedoesdev]

@falcon027 fixed in version 4.1.4

[falcon027]

I appreciate the quick fix, it works now, have a good day.