Request Streaming Example

zio · Mar 2, 2022 · a236750 · a236750 · github-actions · Mar 2, 2022
1 parent 8e4f6bf
commit a236750
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/example/src/main/scala/example/RequestStreaming.scala b/example/src/main/scala/example/RequestStreaming.scala
@@ -0,0 +1,16 @@
+package example
+
+import zhttp.http._
+import zhttp.service.Server
+import zio._
+object RequestStreaming extends App {
+
+  // Create HTTP route which echos back the request body as Stream
+  val app: HttpApp[Any, Nothing] = Http.collect[Request] { case req @ Method.POST -> !! / "echo" =>
+    Response(data = HttpData.fromStream(req.bodyAsStream))
+  }
+
+  // Run it like any simple app
+  override def run(args: List[String]): URIO[zio.ZEnv, ExitCode] =
+    Server.start(8090, app).exitCode
+}