Update example

softwaremill · Sep 25, 2024 · a67939b · a67939b
1 parent d9897da
commit a67939b
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/examples3/src/main/scala/sttp/client4/examples/WebSocketOx.scala b/examples3/src/main/scala/sttp/client4/examples/WebSocketOx.scala
@@ -10,16 +10,13 @@ import sttp.ws.WebSocketFrame
 
 @main def wsOxExample =
   def useWebSocket(ws: SyncWebSocket): Unit =
-    supervised {
+    supervised:
       val inputs = Source.fromValues(1, 2, 3).map(i => WebSocketFrame.text(s"Frame no $i"))
       val (wsSource, wsSink) = asSourceAndSink(ws)
-      fork {
-        inputs.pipeTo(wsSink)
-      }
-      wsSource.foreach { frame =>
+      fork:
+        inputs.pipeTo(wsSink, propagateDone = true)
+      wsSource.foreach: frame =>
         println(s"RECEIVED: $frame")
-      }
-    }
 
   val backend = DefaultSyncBackend()
   try