Close #54

Author: penguin-boxx

README.adoc

@@ -166,20 +166,20 @@ $ cd ./lambdarpc-core/build/dokka/html
 [sources,bash]
 ----
 $ cd LambdaRPC.kt
-$ ./gradlew :examples:ml.dataservice
-$ ./gradlew :examples:ml.mlservice
-$ ./gradlew :examples:ml.client
+$ ./gradlew :examples:interactive-ml:dataservice
+$ ./gradlew :examples:interactive-ml:mlservice
+$ ./gradlew :examples:interactive-ml:client
 ----
 
 * `promise_pipeline` -- an interesting example that shows the possibility to build lazy data processing pipelines using common λRPC functionality.
 
 [sources,bash]
 ----
 $ cd LambdaRPC.kt
-$ ./gradlew :examples:promise.service --args=8090
-$ ./gradlew :examples:promise.service --args=8091
+$ ./gradlew :examples:promise-pipeline:service --args=8090
+$ ./gradlew :examples:promise-pipeline:service --args=8091
 # Any number of services on different ports
-$ ./gradlew :examples:promise.client --args='8090 8091' # Ports of all services
+$ ./gradlew :examples:promise-pipeline:client --args='8090 8091' # Ports of all services
 ----
 
 .lambdarpc-core

examples/build.gradle.kts examples/interactive-ml/build.gradle.kts

@@ -22,35 +22,21 @@ dependencies {
     implementation("io.github.microutils:kotlin-logging-jvm:2.1.21")
 }
 
-val lazy = "io.lambdarpc.examples.promise_pipeline"
-
-tasks.register<JavaExec>("promise.service") {
-    dependsOn("classes")
-    classpath = sourceSets["main"].runtimeClasspath
-    mainClass.set("$lazy.service.ServiceKt")
-}
-
-tasks.register<JavaExec>("promise.client") {
-    dependsOn("classes")
-    classpath = sourceSets["main"].runtimeClasspath
-    mainClass.set("$lazy.client.ClientKt")
-}
-
 val ml = "io.lambdarpc.examples.interactive_ml"
 
-tasks.register<JavaExec>("ml.dataservice") {
+tasks.register<JavaExec>("dataservice") {
     dependsOn("classes")
     classpath = sourceSets["main"].runtimeClasspath
     mainClass.set("$ml.dataservice.ServiceKt")
 }
 
-tasks.register<JavaExec>("ml.mlservice") {
+tasks.register<JavaExec>("mlservice") {
     dependsOn("classes")
     classpath = sourceSets["main"].runtimeClasspath
     mainClass.set("$ml.mlservice.ServiceKt")
 }
 
-tasks.register<JavaExec>("ml.client") {
+tasks.register<JavaExec>("client") {
     dependsOn("classes")
     classpath = sourceSets["main"].runtimeClasspath
     mainClass.set("$ml.client.ClientKt")

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/Defs.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/Defs.kt

@@ -0,0 +1,37 @@
+import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
+
+plugins {
+    kotlin("jvm")
+    kotlin("plugin.serialization") version "1.6.10"
+    application
+}
+
+tasks.withType<KotlinCompile>().all {
+    kotlinOptions {
+        freeCompilerArgs = listOf("-Xopt-in=kotlin.RequiresOptIn")
+        jvmTarget = "11"
+    }
+}
+
+dependencies {
+    implementation(kotlin("stdlib"))
+    implementation(project(":lambdarpc-core"))
+    api("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.6.0")
+    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.3.2")
+    implementation("org.slf4j:slf4j-simple:1.7.36")
+    implementation("io.github.microutils:kotlin-logging-jvm:2.1.21")
+}
+
+val lazy = "io.lambdarpc.examples.promise_pipeline"
+
+tasks.register<JavaExec>("service") {
+    dependsOn("classes")
+    classpath = sourceSets["main"].runtimeClasspath
+    mainClass.set("$lazy.service.ServiceKt")
+}
+
+tasks.register<JavaExec>("client") {
+    dependsOn("classes")
+    classpath = sourceSets["main"].runtimeClasspath
+    mainClass.set("$lazy.client.ClientKt")
+}

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/client/Client.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/client/Client.kt

@@ -0,0 +1,35 @@
+@file:Suppress("SpellCheckingInspection")
+
+package io.lambdarpc.examples.promise_pipeline
+
+import io.lambdarpc.coding.Coder
+import io.lambdarpc.dsl.f
+import io.lambdarpc.dsl.j
+import kotlinx.coroutines.async
+import kotlinx.coroutines.coroutineScope
+
+typealias Promise<R> = suspend () -> R
+
+inline fun <reified R> p(rc: Coder<R> = j()): Coder<Promise<R>> = f(rc)
+
+fun <R> lazify(f: suspend () -> R): suspend () -> Promise<R> = {
+    { f() }
+}
+
+fun <A, R> lazify(
+    f: suspend (A) -> R
+): suspend (Promise<A>) -> Promise<R> = { a ->
+    { f(a()) }
+}
+
+fun <A, B, R> lazify(
+    f: suspend (A, B) -> R
+): suspend (Promise<A>, Promise<B>) -> Promise<R> = { a, b ->
+    {
+        coroutineScope {
+            val aa = async { a() }
+            val bb = async { b() }
+            f(aa.await(), bb.await())
+        }
+    }
+}

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Facade.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Facade.kt

@@ -0,0 +1,20 @@
+package io.lambdarpc.examples.promise_pipeline.client
+
+import io.lambdarpc.dsl.ServiceDispatcher
+import io.lambdarpc.dsl.blockingConnectionPool
+import io.lambdarpc.examples.promise_pipeline.service.*
+import io.lambdarpc.utils.Endpoint
+
+fun main(args: Array<String>) = blockingConnectionPool(
+    ServiceDispatcher(serviceId to args.map {
+        Endpoint("localhost", it.toInt())
+    })
+) {
+    val s = s()
+    val a = a(s)
+    val b = List(10) { b }.fold(a) { b, f -> f(b) }
+    val c = c(s, 2)
+    val d = d(c)
+    val e = e(b, d)
+    println("The answer is: ${e()}")
+}

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Lib.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Lib.kt

@@ -0,0 +1,42 @@
+package io.lambdarpc.examples.promise_pipeline.service
+
+import io.lambdarpc.dsl.LibService
+import io.lambdarpc.dsl.def
+import io.lambdarpc.dsl.j
+import io.lambdarpc.examples.promise_pipeline.Promise
+import io.lambdarpc.examples.promise_pipeline.lazify
+import io.lambdarpc.examples.promise_pipeline.p
+import io.lambdarpc.utils.Endpoint
+import io.lambdarpc.utils.toSid
+
+val serviceId = "d5ec2813-4468-4deb-b156-aeba87b91bd6".toSid()
+
+val s by serviceId.def(p<Int>())
+val a by serviceId.def(p<Int>(), p<Int>())
+val b by serviceId.def(p<Int>(), p<Int>())
+val c by serviceId.def(p<Int>(), j<Int>(), p<Int>())
+val d by serviceId.def(p<Int>(), p<Int>())
+val e by serviceId.def(p<Int>(), p<Int>(), p<Int>())
+
+private object Lib {
+    fun s(): Int = 1
+    fun a(x: Int): Int = x + 1
+    fun b(x: Int): Int = x + 3
+    suspend fun c(x: Promise<Int>, k: Int): Promise<Int> = { x() * k }
+    fun d(x: Int): Int = x + 8
+    fun e(x: Int, y: Int): Int = x + y
+}
+
+fun main(args: Array<String>) {
+    val (port) = args
+    val service = LibService(serviceId, Endpoint("localhost", port.toInt())) {
+        s of lazify(Lib::s)
+        a of lazify(Lib::a)
+        b of lazify(Lib::b)
+        c of Lib::c
+        d of lazify(Lib::d)
+        e of lazify(Lib::e)
+    }
+    service.start()
+    service.awaitTermination()
+}

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Service.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/dataservice/Service.kt

@@ -27,9 +27,9 @@ dependencies {
     api("com.google.protobuf:protobuf-java-util:3.19.4")
     api("com.google.protobuf:protobuf-kotlin:3.19.4")
     api("io.grpc:grpc-kotlin-stub:1.2.1")
-    implementation("org.jetbrains.kotlinx:kotlinx-serialization-json:1.3.2")
-    implementation("org.slf4j:slf4j-simple:1.7.36")
-    implementation("io.github.microutils:kotlin-logging-jvm:2.1.21")
+    api("org.jetbrains.kotlinx:kotlinx-serialization-json:1.3.2")
+    api("org.slf4j:slf4j-simple:1.7.36")
+    api("io.github.microutils:kotlin-logging-jvm:2.1.21")
     detektPlugins("io.gitlab.arturbosch.detekt:detekt-formatting:1.19.0")
 
     testImplementation(kotlin("test"))

examples/src/main/kotlin/io/lambdarpc/examples/interactive_ml/mlservice/Facade.kt examples/interactive-ml/src/main/kotlin/io/lambdarpc/examples/interactive_ml/mlservice/Facade.kt

@@ -1,4 +1,8 @@
 rootProject.name = "lambdarpc-kt"
-include("lambdarpc-core")
-include("lambdarpc-coders")
-include("examples")
+include(
+    ":lambdarpc-core",
+    ":lambdarpc-coders",
+    ":examples:interactive-ml",
+    ":examples:promise-pipeline",
+    ":benchmarks:grpc"
+)