| cats.effect.IOFiber@3ae5495a RUNNING | |
| ├ flatMap @ catseffect.examples.LiveFiberSnapshot$.$anonfun$loop$2(IOAppSpec.scala:294) | |
| ├ map @ catseffect.examples.LiveFiberSnapshot$.loop$lzycompute(IOAppSpec.scala:293) | |
| ├ flatMap @ catseffect.examples.LiveFiberSnapshot$.$anonfun$loop$2(IOAppSpec.scala:294) | |
| ├ map @ catseffect.examples.LiveFiberSnapshot$.loop$lzycompute(IOAppSpec.scala:293) | |
| ├ flatMap @ catseffect.examples.LiveFiberSnapshot$.$anonfun$loop$2(IOAppSpec.scala:294) | |
| ├ map @ catseffect.examples.LiveFiberSnapshot$.loop$lzycompute(IOAppSpec.scala:293) | |
| ├ flatMap @ catseffect.examples.LiveFiberSnapshot$.$anonfun$loop$2(IOAppSpec.scala:294) | |
| ├ >> @ catseffect.examples.LiveFiberSnapshot$.loop$lzycompute(IOAppSpec.scala:294) | |
| ├ flatMap @ catseffect.examples.LiveFiberSnapshot$.$anonfun$loop$2(IOAppSpec.scala:294) |
| [error] cats.effect.IOFiber@494388963 RUNNING | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:27) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:27) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:27) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:27) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:27) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:27) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:27) |
| [error] cats.effect.IOFiber@766695369 RUNNING | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:26) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:26) |
| [error] cats.effect.IOFiber@58d4928e RUNNING | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:26) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) | |
| [error] ├ flatMap @ TestApp$.$anonfun$loop$2(TestApp.scala:26) | |
| [error] ├ map @ TestApp$.loop$lzycompute(TestApp.scala:25) | |
| [error] ├ >> @ TestApp$.loop$lzycompute(TestApp.scala:26) |
| /* | |
| * Copyright 2020-2021 Typelevel | |
| * | |
| * Licensed under the Apache License, Version 2.0 (the "License"); | |
| * you may not use this file except in compliance with the License. | |
| * You may obtain a copy of the License at | |
| * | |
| * http://www.apache.org/licenses/LICENSE-2.0 | |
| * | |
| * Unless required by applicable law or agreed to in writing, software |
| final override def map2[A, B, Z](fa: ParallelF[F, A], fb: ParallelF[F, B])( | |
| f: (A, B) => Z): ParallelF[F, Z] = | |
| ParallelF( | |
| F.uncancelable { poll => | |
| for { | |
| fiberA <- F.start(ParallelF.value(fa)) | |
| fiberB <- F.start(ParallelF.value(fb)) | |
| // start a pair of supervisors to ensure that the opposite is canceled on error | |
| _ <- F start { |
This document describes the general outcome we want for users as well as a few ideas on how we should do this. It shouldn't be considered prescriptive or precise though; if we come up with better ideas along the way, we should do them instead!
Users should be able to run something like the following:
$ sbt new typelevel/serverless.g8 --branch aws/http
I'm going to do something that I don't normally do, which is to say I'm going to talk about comparative benchmarks. In general, I try to confine performance discussion to absolute metrics as much as possible, or comparisons to other well-defined neutral reference points. This is precisely why Cats Effect's readme mentions a comparison to a fixed thread pool, rather doing comparisons with other asynchronous runtimes like Akka or ZIO. Comparisons in general devolve very quickly into emotional marketing.
But, just once, today we're going to talk about the emotional marketing. In particular, we're going to look at Cats Effect 3 and ZIO 2. Now, for context, as of this writing ZIO 2 has released their first milestone; they have not released a final 2.0 version. This implies straight off the bat that we're comparing apples to oranges a bit, since Cats Effect 3 has been out and in production for months. However, there has been a post going around which cites various compar
| Summary: | |
| Total: 9.4541 secs | |
| Slowest: 6.4380 secs | |
| Fastest: 0.2701 secs | |
| Average: 4.2429 secs | |
| Requests/sec: 21.1547 | |
| Response time histogram: | |
| 0.270 [1] |■ |
| diff --git a/examples/ember/src/main/scala/com/example/http4s/ember/EmberServerSimpleExample.scala b/examples/ember/src/main/scala/com/example/http4s/ember/EmberServerSimpleExample.scala | |
| index e103ff09171..44e3c02a48c 100644 | |
| --- a/examples/ember/src/main/scala/com/example/http4s/ember/EmberServerSimpleExample.scala | |
| +++ b/examples/ember/src/main/scala/com/example/http4s/ember/EmberServerSimpleExample.scala | |
| @@ -61,6 +61,24 @@ object EmberServerSimpleExample extends IOApp { | |
| Ok(Json.obj("root" -> Json.fromString("GET"))) | |
| case GET -> Root / "hello" / name => | |
| Ok(show"Hi $name!") | |
| + case req @ POST -> Root / "wut" => | |
| + Ok { |