lbialy

//> using scala "3.1.1"

// let's start with basic functor because all monads in scala have to be functors to work
// within a for-comprehension (because it desugars to flatMap + map chain)
// F[_] represents any concrete type parameterised with a single type (a type constructor), ie List, Option
trait Functor[F[_]]:
  def map[A, B](fa: F[A])(f: A => B): F[B]

// define a correct interface for a Monad that extends that Functor, Monad is just
// two functions: pure (return in hs) and flatMap (bind in hs)

lbialy

//> using scala "3.2"

import scala.concurrent.*, duration.*
import scala.collection.*
import java.util.concurrent.ExecutorService
import scala.language.implicitConversions
import java.util.concurrent.locks.ReentrantLock

object Looming:
  sealed trait LoomingExecutionContext

lbialy

//> using lib "com.softwaremill.sttp.openai::core:0.0.6"

object ai:
  import scala.quoted.*
  import sttp.openai.OpenAISyncClient
  import sttp.openai.requests.completions.chat.*
  import sttp.openai.requests.completions.chat.ChatRequestBody.ChatBody
  import sttp.openai.requests.completions.chat.ChatRequestBody.ChatCompletionModel

  opaque type GPT[A <: String] <: String = String

lbialy

//> using scala "3.3.0"

import scala.concurrent.*, ExecutionContext.Implicits.global, duration.*
import scala.util.boundary, boundary.*

def runsOnAnotherThread(msg: String): Future[Unit] = 
  Future:
    println(s"This: $msg runs on ${Thread.currentThread.getName}")

def runTest(): Future[String] = 

lbialy

//> using scala "3.3.0"

import scala.concurrent.*, ExecutionContext.Implicits.global, duration.*
import scala.util.boundary, boundary.*

def runsOnAnotherThread(msg: String): Future[Unit] = 
  Future:
    println(s"This: $msg runs on ${Thread.currentThread.getName}")

def testFatals(): Future[String] = 

lbialy

//> using lib "io.github.martinhh::scalacheck-derived:0.4.1"
//> using lib "org.scalacheck::scalacheck:1.17.0"
//> using lib "io.scalaland::chimney:0.8.0-M1"
//> using lib "org.openjdk.jmh:jmh-core:1.37"

package local.mutability

import scala.collection.mutable
import io.scalaland.chimney.dsl.*

lbialy

#!/usr/bin/env bash

username=
password=
stagedRepositoryId=

while [ "$1" != "" ]; do
    case $1 in
        -u | --username)
            shift

lbialy

A structured concurrency response to https://twitter.com/alexelcu/status/1710305127729438994

I am using Ox and JDK 21 in this gist.

First run: docker run --name test-postgres -p 5432:5432 -e POSTGRES_PASSWORD=postgres -d postgres

Then: scala-cli run ox-jdbc.scala

lbialy

<?xml version="1.0" encoding="UTF-8"?>
<project
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
        xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

    <modelVersion>4.0.0</modelVersion>

    <groupId>org.jetbrains.kotlin.examples</groupId>
    <artifactId>hello-world</artifactId>
    <version>1.0-SNAPSHOT</version>

lbialy

// AppKt.java
package hello;

import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.CoroutineContext;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.SourceDebugExtension;