Cosmetics - replaced Chunk.apply with Chunk.singleton.

softwaremill · Dec 14, 2023 · c069e88 · c069e88
1 parent 7a9d408
commit c069e88
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/server/http4s-server/src/main/scala/sttp/tapir/server/http4s/Http4sWebSockets.scala b/server/http4s-server/src/main/scala/sttp/tapir/server/http4s/Http4sWebSockets.scala
@@ -45,7 +45,7 @@ private[http4s] object Http4sWebSockets {
           val ignorePongs = optionallyIgnorePong(concatenated, o.ignorePong)
           val autoPongs = optionallyAutoPong(ignorePongs, c, o.autoPongOnPing)
           val autoPings = o.autoPing match {
-            case Some((interval, frame)) => (c.send(Chunk(frameToHttp4sFrame(frame))) >> Temporal[F].sleep(interval)).foreverM[Unit]
+            case Some((interval, frame)) => (c.send(Chunk.singleton(frameToHttp4sFrame(frame))) >> Temporal[F].sleep(interval)).foreverM[Unit]
             case None => Applicative[F].unit
           }
 
@@ -64,7 +64,7 @@ private[http4s] object Http4sWebSockets {
 
           c.stream
             .concurrently(Stream.exec((outputProducer >> c.close.void, autoPings).parTupled.void))
-            .append(Stream(Chunk(frameToHttp4sFrame(WebSocketFrame.close))))
+            .append(Stream(Chunk.singleton(frameToHttp4sFrame(WebSocketFrame.close))))
             .unchunks
       }
     }
@@ -122,7 +122,7 @@ private[http4s] object Http4sWebSockets {
     if (doAuto) {
       val trueF = true.pure[F]
       s.evalFilter {
-        case ping: WebSocketFrame.Ping => c.send(Chunk(frameToHttp4sFrame(WebSocketFrame.Pong(ping.payload)))).map(_ => false)
+        case ping: WebSocketFrame.Ping => c.send(Chunk.singleton(frameToHttp4sFrame(WebSocketFrame.Pong(ping.payload)))).map(_ => false)
         case _ => trueF
       }
     } else s