krishnabhargav

import infrastructure.Json
import io.javalin.Javalin
import io.javalin.plugin.json.FromJsonMapper
import io.javalin.plugin.json.JavalinJson
import io.javalin.plugin.json.ToJsonMapper

sealed class Device {
    data class Laptop(val model: String) : Device()
    data class Phone(val model: String, val carrier: String): Device()
}

krishnabhargav

import infrastructure.Json
import io.javalin.Javalin
import io.javalin.http.Context
import io.javalin.http.HandlerType
import io.javalin.plugin.json.FromJsonMapper
import io.javalin.plugin.json.JavalinJson
import io.javalin.plugin.json.ToJsonMapper

fun main() {
    val app: Javalin = Javalin.create().start(7000)

krishnabhargav

import kotlinx.coroutines.FlowPreview
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.runBlocking
import kotlin.random.Random

@FlowPreview
fun main() = runBlocking {
    val events = eventStoreProducer()
    val messages = kafkaProducer()