Skip to content

Instantly share code, notes, and snippets.

View adamw's full-sized avatar

Adam Warski adamw

808 followers · 1 following
View GitHub Profile
@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()
}
@adamw
adamw / example.yaml
Created October 23, 2020 10:37
asyncapi: 2.0.0
info:
title: JSON echo
version: '1.0'
servers:
dev:
url: localhost:8080
protocol: ws
channels:
/ping:
@adamw
adamw / test.scala
Created October 21, 2020 19:52
import monix.reactive.Observable
import sttp.capabilities.monix.MonixStreams
object Test extends App {
import sttp.client3._
import monix.execution.Scheduler.Implicits.global
val b = AsyncHttpClientMonixBackend().runSyncUnsafe()
basicRequest.post(uri"http://198.51.100.0").streamBody(MonixStreams)(Observable.empty).send(b).runSyncUnsafe()
@adamw
adamw / endpointwiden.scala
Created October 21, 2020 11:02
package sttp.tapir.server.http4s.ztapir
import org.scalatest.flatspec.AnyFlatSpec
import org.scalatest.matchers.should.Matchers
import sttp.monad.MonadError
import zio.{Has, RIO, Runtime, ZIO}
import zio.interop.catz._
import zio.interop.catz.implicits._
import sttp.tapir._
import sttp.tapir.server.ServerEndpoint
@adamw
adamw / ws.scala
Last active September 16, 2020 16:59
package sttp.client3.examples
import monix.eval.Task
import sttp.capabilities.WebSockets
import sttp.capabilities.monix.MonixStreams
import sttp.client3._
import sttp.client3.asynchttpclient.monix.AsyncHttpClientMonixBackend
import sttp.client3.testing.SttpBackendStub
import sttp.model.StatusCode
import sttp.ws.{WebSocket, WebSocketFrame}
@adamw
adamw / json.scala
Last active September 16, 2020 16:59
package sttp.client3.examples
import io.circe.generic.auto._
import sttp.client3._
import sttp.client3.asynchttpclient.monix.AsyncHttpClientMonixBackend
import sttp.client3.circe._
object GetAndParseJsonGetRightMonixCirce extends App {
import monix.execution.Scheduler.Implicits.global
@adamw
adamw / raw.scala
Last active September 16, 2020 16:59
package sttp.client3.examples
import io.circe
import io.circe.generic.auto._
import sttp.client3._
import sttp.client3.circe._
object GetRawRequestBodySynchronous extends App {
case class HttpBinResponse(origin: String, headers: Map[String, String])