support closeOnBackpressureLimit

dimdenGD · Oct 4, 2024 · a322841 · a322841
1 parent 86b523d
commit a322841
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -161,6 +161,7 @@ Below is the list of supported features and their compatibility:
 - ✅ maxBackpressure (uWS only, default `maxPayload`)
 - ✅ idleTimeout (uWS only, default 120)
 - ✅ maxLifetime (uWS only, default 0)
+- ✅ closeOnBackpressureLimit (uWS only, default `false`)
 
 #### Server events
 

diff --git a/src/server.js b/src/server.js
@@ -50,6 +50,9 @@ module.exports = class WebSocketServer extends EventEmitter {
         if(typeof options.WebSocket === 'undefined') {
             options.WebSocket = WebSocket;
         }
+        if(typeof options.closeOnBackpressureLimit === 'undefined') {
+            options.closeOnBackpressureLimit = false;
+        }
 
         if(options.clientTracking) {
             this.clients = new Set();
@@ -77,6 +80,7 @@ module.exports = class WebSocketServer extends EventEmitter {
             maxBackpressure: this.options.maxBackpressure ?? this.options.maxPayload,
             idleTimeout: this.options.idleTimeout ?? 120,
             maxLifetime: this.options.maxLifetime ?? 0,
+            closeOnBackpressureLimit: this.options.closeOnBackpressureLimit,
             compression: typeof this.options.perMessageDeflate !== 'number' && this.options.perMessageDeflate ? 
                 (uWS.DEDICATED_COMPRESSOR_4KB | uWS.DEDICATED_DECOMPRESSOR) : this.options.perMessageDeflate,
             upgrade: async (res, req, context) => {