From 61f0f3e1ce505b57d18c4ba08fd0e7f723578b65 Mon Sep 17 00:00:00 2001 From: Niteesh Kumar Date: Sun, 15 Mar 2026 13:02:29 +0000 Subject: [PATCH] fix(rsocket-core): Pass fragmentation config to server-side responder streams #306 Signed-off-by: Niteesh Kumar --- packages/rsocket-core/src/RSocketServer.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/rsocket-core/src/RSocketServer.ts b/packages/rsocket-core/src/RSocketServer.ts index 24d430e0..e7071125 100644 --- a/packages/rsocket-core/src/RSocketServer.ts +++ b/packages/rsocket-core/src/RSocketServer.ts @@ -69,6 +69,7 @@ export class RSocketServer { this.acceptor = config.acceptor; this.transport = config.transport; this.lease = config.lease; + this.fragmentation = config.fragmentation; this.serverSideKeepAlive = config.serverSideKeepAlive; this.sessionStore = config.resume ? {} : undefined; this.sessionTimeout = config.resume?.sessionTimeout ?? undefined; @@ -154,7 +155,7 @@ export class RSocketServer { ); const streamsHandler = new DefaultStreamRequestHandler( responder, - 0 + this.fragmentation?.maxOutboundFragmentSize ?? 0, ); connection.onClose((e) => {