Added note to handle backpressure

PantelisGeorgiadis · Feb 26, 2024 · 5e0e9e7 · 5e0e9e7
1 parent ee90f7b
commit 5e0e9e7
Showing 1 changed file with 3 additions and 14 deletions.
diff --git a/src/Network.js b/src/Network.js
@@ -509,19 +509,6 @@ class Network extends AsyncEventEmitter {
     }
   }
 
-  /**
-   * Write PDV data to stream while handling backpressure.
-   * @method
-   * @private
-   * @param {Writable} stream - The store writable stream.
-   * @param {PDataTF} pdu - PDU.
-   */
-  _writePdvToStream(stream, pdv) {
-    if (!stream.write(pdv.getValue())) {
-      stream.once('drain', () => this._writePdvToStream(stream, pdv));
-    }
-  }
-
   /**
    * Process P-DATA-TF.
    * @method
@@ -561,7 +548,9 @@ class Network extends AsyncEventEmitter {
         }
 
         const stream = this.dimseStream || this.dimseStoreStream;
-        this._writePdvToStream(stream, pdv);
+
+        // TODO: Add stream backpressure event handling
+        stream.write(pdv.getValue());
 
         if (pdv.isLastFragment()) {
           if (pdv.isCommand()) {