From f2d31b8ececdbfc8f229514d9678faa6520e97e7 Mon Sep 17 00:00:00 2001 From: Sheikah45 Date: Thu, 12 Oct 2023 18:46:31 -0400 Subject: [PATCH] Use config buffersize to aggregate frames --- .../main/kotlin/com/faforever/commons/lobby/FafLobbyClient.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faf-commons-lobby/src/main/kotlin/com/faforever/commons/lobby/FafLobbyClient.kt b/faf-commons-lobby/src/main/kotlin/com/faforever/commons/lobby/FafLobbyClient.kt index ae9699f3..d7c5b089 100644 --- a/faf-commons-lobby/src/main/kotlin/com/faforever/commons/lobby/FafLobbyClient.kt +++ b/faf-commons-lobby/src/main/kotlin/com/faforever/commons/lobby/FafLobbyClient.kt @@ -150,7 +150,7 @@ class FafLobbyClient( return webSocketClient .uri(config.url) .handle { inbound, outbound -> - val inboundMono = inbound.aggregateFrames(100 * 1024 * 1024) + val inboundMono = inbound.aggregateFrames(config.bufferSize) .receive() .asString(Charsets.UTF_8) .doOnError { LOG.error("Inbound channel closed with error", it) }