From d4f16ad0a19767bf01a47581fd8997de50916e2f Mon Sep 17 00:00:00 2001 From: Aleksander Sorokin Date: Wed, 18 Sep 2024 19:02:57 +0300 Subject: [PATCH] fix SendResult handling in ConHubImpl for batch message sending (#137) --- src/main/scala/com/evolutiongaming/conhub/ConHubImpl.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/scala/com/evolutiongaming/conhub/ConHubImpl.scala b/src/main/scala/com/evolutiongaming/conhub/ConHubImpl.scala index 7fca302..788152c 100644 --- a/src/main/scala/com/evolutiongaming/conhub/ConHubImpl.scala +++ b/src/main/scala/com/evolutiongaming/conhub/ConHubImpl.scala @@ -130,6 +130,8 @@ object ConHubImpl extends LazyLogging { for {remoteMsgs <- Nel.opt(remoteMsgs)} sendMsgs.remote(remoteMsgs, Nil) + val cons = msgsAndCons.flatMap { case (_, cons) => cons } + future map { _ => SendResult(cons) } }