calvinlfer

import org.http4s.*
import org.http4s.dsl.*
import zio.{durationInt as _, *}
import zio.interop.catz.*
import com.comcast.ip4s.*
import fs2.*
import org.http4s.ember.server.EmberServerBuilder
import fs2.io.net.Network

val example =

calvinlfer

import cats.effect.Resource
import com.fasterxml.jackson.databind.JsonNode
import fs2.kafka.*
import io.circe.Decoder
import io.circe.jackson.jacksonToCirce
import io.confluent.kafka.schemaregistry.client.{CachedSchemaRegistryClient, SchemaRegistryClient}
import io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializer
import io.confluent.kafka.serializers.json.KafkaJsonSchemaDeserializerConfig.*
import zio.*
import zio.interop.catz.*

calvinlfer

//> using dep dev.zio::zio:2.1.19
//> using dep dev.zio::zio-interop-cats::23.1.0.5
//> using dep dev.zio::zio-http:3.3.3

import zio.http.*
import zio.*
import zio.stream.*
import zio.http.WebSocketFrame.*

final class ChatRoom(in: Queue[WebSocketFrame], out: Hub[WebSocketChannelEvent]):

calvinlfer

import zio.*
import zio.telemetry.opentelemetry.OpenTelemetry
import io.opentelemetry.sdk.OpenTelemetrySdk
import io.opentelemetry.api.metrics.MeterProvider
import io.opentelemetry.sdk.metrics.SdkMeterProvider
import io.opentelemetry.exporter.otlp.metrics.OtlpGrpcMetricExporter
import io.opentelemetry.exporter.otlp.logs.OtlpGrpcLogRecordExporter
import io.opentelemetry.sdk.metrics.`export`.PeriodicMetricReader
import io.opentelemetry.sdk.resources.Resource as OltpResource
import zio.metrics.Metric

calvinlfer

//> using scala 3.6.3

import scala.deriving.Mirror
import scala.compiletime.{erasedValue}

/** Type-level function that transforms a type-level tuple of types
  * into a corresponding tuple of List[...] at the value level.
  *
  * E.g., if Ts is (T1, T2, T3), Partitioned[Ts] is (List[T1], List[T2], List[T3]).
  */

calvinlfer

import cats.syntax.parallel.*
import cats.effect.*
import fs2.*
import fs2.interop.flow.*
import io.helidon.config.Config
import io.helidon.messaging.connectors.kafka.KafkaConfigBuilder.AutoOffsetReset
import io.helidon.messaging.connectors.kafka.{KafkaConnector as HelidonKafkaConnector, KafkaMessage, KafkaPublisher as HelidonKafkaConsumer}
import org.apache.kafka.common.serialization.StringDeserializer
import org.reactivestreams.FlowAdapters

calvinlfer

apk add --update openjdk21 curl

# Use JAR based launcher: https://get-coursier.io/docs/cli-installation#linux--macos
curl -fLo coursier https://github.com/coursier/launchers/raw/master/coursier
chmod +x coursier

# Install SBT
./coursier install sbt

# https://get-coursier.io/docs/cli-launch#java-options

calvinlfer

import zio.*
import scala.Console as SConsole
import scala.io.StdIn
import java.io.{BufferedReader, IOException}
import scala.util.Try

object InterruptibleReadLineExample extends ZIOAppDefault {

  def altReadLine(reader: BufferedReader = SConsole.in) = 
    ZIO

calvinlfer

import kyo.*
import kyo.Emit.Ack

object Playground extends KyoApp:
  def recursiveStream(start: Int): Stream[Int, IO] =
    def go(n: Int): Ack < Emit[Chunk[Int]] =
      Emit.andMap(Chunk(n)):
        case Ack.Stop        => Ack.Stop
        case Ack.Continue(_) => go(n + 1)

calvinlfer

import com.sksamuel.avro4s.{Decoder, SchemaFor}
import fs2.kafka.{Deserializer, ValueDeserializer, KeyDeserializer}
import fs2.kafka.vulcan.AvroSettings
import cats.effect.{Sync, Resource}
import java.nio.ByteBuffer
import io.confluent.kafka.schemaregistry.avro.AvroSchema

final class Avro4sDeserializer[A >: Null](
  private val decoder: Decoder[A],
  private val schemaFor: SchemaFor[A]