adamw

val ae = IO.async[Unit] { cb =>
  ec3.submit(new Runnable {
    override def run(): Unit = {
      println(Thread.currentThread().getName + " (async)")
      cb(Left(new IllegalStateException()))
    }
  })
}

run("async error") {

adamw

run("async shift") {
  a *> IO.shift(ec1) *> printThread
}

/*
Outputs:

-- async shift --
ec3-1-785992331 (async)
ec1-2-274064559

adamw

import tapir.docs.openapi._
import tapir.openapi.circe.yaml._
val yaml = List(petEndpoint).toOpenAPI("Our pets", "1.0").toYaml

adamw

implicit val runtime: DefaultRuntime = new DefaultRuntime {}

val serve = BlazeServerBuilder[Task]
  .bindHttp(8080, "localhost")
  .withHttpApp(Router("/" -> service).orNotFound)
  .serve
  .compile
  .drain

runtime.unsafeRun(serve)

adamw

val service: HttpRoutes[Task] = petEndpoint.toZioRoutes { petId =>
  if (petId == 35) {
    UIO(Pet("Tapirus terrestris", "https://en.wikipedia.org/wiki/Tapir"))
  } else {
    IO.fail("Unknown pet id")
  }
}

adamw

case class Pet(species: String, url: String)
import tapir._
import io.circe.generic.auto._
import tapir.json.circe._

val petEndpoint: Endpoint[Int, String, Pet, Nothing] =
  endpoint
    .get
    .in("pet" / path[Int]("petId"))
    .errorOut(stringBody)

adamw

package tapir.example

import org.http4s.{EntityBody, HttpRoutes}
import scalaz.zio.{IO, Task}
import tapir.Endpoint
import tapir.server.http4s.Http4sServerOptions
import scalaz.zio.interop.catz._
import tapir.server.ServerEndpoint

package object zio {

adamw

val e: Endpoint[Int, String, Pet, Nothing] = endpoint
  .get
  .in("pet" / path[Int]("petId"))
  .errorOut(stringBody)
  .out(jsonBody[Pet])

adamw

run("async 2") {
  (printThread *> a *> printThread).on(ec1)
}

/*
Outputs:

-- async 2 --
ec1-1-716083600
ec3-1-1627960023 (async)

adamw

val a = IO.effectAsync[Any, Nothing, Unit] { cb =>
  ec3.submit(new Runnable {
    override def run(): Unit = {
      println(Thread.currentThread().getName + " (async)")
      cb(UIO.unit)
    }
  })
}

run("async") {