This commit is contained in:
Maksim Fomenkov
2022-11-09 03:10:42 +03:00
parent e8d12c5584
commit 87381b9946

View File

@@ -240,7 +240,7 @@ open class WsConnection(
.aggregateFrames(msgSizeLimit)
.receiveFrames()
.map { ByteBufInputStream(it.content()).readAllBytes() }
.filter{ it.isNotEmpty() }
.filter { it.isNotEmpty() }
.flatMap {
try {
val msg = parser.parse(it)