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) } }