back to traverse

http4s · Feb 4, 2023 · 21756fd · 21756fd
1 parent 361b0ca
commit 21756fd
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/client/src/main/scala/org/http4s/netty/client/Http4sWebsocketHandler.scala b/client/src/main/scala/org/http4s/netty/client/Http4sWebsocketHandler.scala
@@ -140,14 +140,7 @@ private[client] class Http4sWebsocketHandler[F[_]](
 
     override def sendMany[G[_], A <: WSFrame](wsfs: G[A])(implicit G: Foldable[G]): F[Unit] =
       if (ctx.channel().isActive) {
-        runInNetty(F.delay {
-          if (ctx.channel().isActive) {
-            val list = wsfs.toList
-            list.foreach(wsf => ctx.write(fromWSFrame(wsf)))
-            ctx.flush()
-          }
-          ()
-        })
+        wsfs.traverse_(wsf => runInNetty(F.delay(ctx.writeAndFlush(fromWSFrame(wsf))).liftToF))
       } else {
         closed.complete(()).void
       }