Skip to content

Instantly share code, notes, and snippets.

View adamw's full-sized avatar

Adam Warski adamw

766 followers · 1 following
View GitHub Profile
@adamw
adamw / accumulator.sc
Created July 20, 2023 12:44
//> using dep com.softwaremill.ox::core:0.0.7
import ox.*
import ox.channels.*
import scala.annotation.tailrec
scoped {
// fast producer
val c = Channel[Int]()
fork {
@adamw
adamw / update_signature.md
Created May 26, 2023 16:17 
.libv1> builtins.merge

test1: Nat -> Nat
test1 n = n + n
@adamw
adamw / x.scala
Created October 13, 2022 10:16
package sttp.tapir.examples
import cats.effect.{ExitCode, IO, IOApp}
import org.http4s.HttpRoutes
import org.http4s.blaze.server.BlazeServerBuilder
import org.http4s.server.Router
import sttp.model.{Part, StatusCode}
import sttp.model.headers.WWWAuthenticateChallenge
import sttp.tapir._
import sttp.tapir.generic.auto._
@adamw
adamw / HelloWorldAkkaServer.scala
Created September 16, 2022 10:37
package sttp.tapir.examples
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Route
import scala.concurrent.{Await, Future}
import scala.concurrent.duration._
import scala.io.StdIn
@adamw
adamw / gen.scala
Created September 6, 2022 07:15
How to generate an exhaustive match for a sealed trait in a Scala 3 macro?
// TestMacro.scala
import scala.quoted.*
object TestMacro {
inline def name[E](e: E): String = ${ nameImpl[E]('e) }
def nameImpl[E: Type](e: Expr[E])(using Quotes): Expr[String] = {
import quotes.reflect.*
@adamw
adamw / test.scala
Created June 10, 2022 17:03
object UsingIO:
trait Connection
trait User
case class IO[-R, +A]():
def *>[R1 <: R, B](that: => IO[R1, B]): IO[R1, B] = IO()
def foo(): IO[Connection, Unit] = IO()
def bar(): IO[User, Unit] = IO()
@adamw
adamw / x.scala
Last active March 31, 2022 14:20
opaque type NonEmptyString = String
object NonEmptyString:
def apply(s: String): Option[NonEmptyString] =
if s.isEmpty then None else Some(s)
@adamw
adamw / gist:d06722ab6826aad108beca979065a90b
Created April 27, 2021 12:10
"pool-48-thread-5" #225 prio=5 os_prio=31 cpu=172535.04ms elapsed=180.55s tid=0x00007fd765e3d800 nid=0xdd0b runnable [0x0000700019eb4000]
java.lang.Thread.State: RUNNABLE
at dotty.tools.dotc.core.Types$Type.classSymbol(Types.scala:488)
at dotty.tools.dotc.transform.patmat.SpaceEngine.canDecompose(Space.scala:649)
at dotty.tools.dotc.transform.patmat.SpaceLogic.simplify(Space.scala:147)
at dotty.tools.dotc.transform.patmat.SpaceLogic.simplify$(Space.scala:78)
at dotty.tools.dotc.transform.patmat.SpaceEngine.simplify(Space.scala:323)
at dotty.tools.dotc.transform.patmat.SpaceLogic.isSubspace(Space.scala:176)
at dotty.tools.dotc.transform.patmat.SpaceLogic.isSubspace$(Space.scala:78)
at dotty.tools.dotc.transform.patmat.SpaceEngine.isSubspace(Space.scala:323)
@adamw
adamw / test.scala
Created April 15, 2021 07:56
package sttp.tapir.examples
import cats.effect._
import cats.syntax.all._
import org.http4s.HttpRoutes
import org.http4s.server.Router
import org.http4s.server.blaze.BlazeServerBuilder
import org.http4s.syntax.kleisli._
import sttp.client3._
import sttp.tapir._
@adamw
adamw / tapir.scala
Last active February 19, 2021 17:16
trait TapirHandler extends RequestStreamHandler {
def endpoints: List[ServerEndpoint[_, _, _, Any, Identity]]
override def handleRequest(input: InputStream, output: OutputStream,
context: Context): Unit = {
val json = new String(input.readAllBytes(), UTF_8)
val writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8))
writer.write(handleRequest(json))
writer.flush()
}