WIP

Author: whyoleg

benchmarks/rsocket-java/src/jvmMain/kotlin/RSocketJavaBenchmark.kt

@@ -96,12 +96,27 @@ abstract class RSocketJavaBenchmark : RSocketBenchmark<Payload, Blackhole>() {
         server.dispose()
     }
 
+//    @Benchmark
+//    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+//
+//    @Benchmark
+//    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+//
+//    @Benchmark
+//    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+
     @Benchmark
-    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+    override fun requestStreamBlocking(bh: Blackhole) {
+        super.requestStreamBlocking(bh)
+    }
 
     @Benchmark
-    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+    override fun requestStreamParallel(bh: Blackhole) {
+        super.requestStreamParallel(bh)
+    }
 
     @Benchmark
-    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+    override fun requestStreamConcurrent(bh: Blackhole) {
+        super.requestStreamConcurrent(bh)
+    }
 }

benchmarks/rsocket-kotlin-old/build.gradle.kts

@@ -80,6 +80,6 @@ benchmark {
     }
 
     configuration("RSocketKotlinOld", "KtorTcp", "text") {
-        param("payloadSize", "0", "64", "8192")
+        param("payloadSize", "0", "64", "4096")
     }
 }

benchmarks/rsocket-kotlin-old/src/commonMain/kotlin/RSocketKotlinOldBenchmark.kt

@@ -81,12 +81,28 @@ abstract class RSocketKotlinOldBenchmark : RSocketBenchmark<Payload, Blackhole>(
         benchJob.cancelAndJoin()
     }
 
+//    @Benchmark
+//    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+//
+//    @Benchmark
+//    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+//
+//    @Benchmark
+//    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+
+
     @Benchmark
-    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+    override fun requestStreamBlocking(bh: Blackhole) {
+        super.requestStreamBlocking(bh)
+    }
 
     @Benchmark
-    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+    override fun requestStreamParallel(bh: Blackhole) {
+        super.requestStreamParallel(bh)
+    }
 
     @Benchmark
-    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+    override fun requestStreamConcurrent(bh: Blackhole) {
+        super.requestStreamConcurrent(bh)
+    }
 }

benchmarks/rsocket-kotlin/src/commonMain/kotlin/RSocketKotlinBenchmark.kt

@@ -80,12 +80,28 @@ abstract class RSocketKotlinBenchmark : RSocketBenchmark<Payload, Blackhole>() {
         benchJob.cancelAndJoin()
     }
 
+//    @Benchmark
+//    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+//
+//    @Benchmark
+//    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+//
+//    @Benchmark
+//    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+
+
     @Benchmark
-    override fun requestResponseBlocking(bh: Blackhole) = super.requestResponseBlocking(bh)
+    override fun requestStreamBlocking(bh: Blackhole) {
+        super.requestStreamBlocking(bh)
+    }
 
     @Benchmark
-    override fun requestResponseParallel(bh: Blackhole) = super.requestResponseParallel(bh)
+    override fun requestStreamParallel(bh: Blackhole) {
+        super.requestStreamParallel(bh)
+    }
 
     @Benchmark
-    override fun requestResponseConcurrent(bh: Blackhole) = super.requestResponseConcurrent(bh)
+    override fun requestStreamConcurrent(bh: Blackhole) {
+        super.requestStreamConcurrent(bh)
+    }
 }

benchmarks/shared/src/commonMain/kotlin/RSocketBenchmark.kt

@@ -42,6 +42,13 @@ abstract class RSocketBenchmark<Payload : Any, Blackhole : Any> {
     open fun requestResponseParallel(bh: Blackhole) = parallel(bh, 1000, ::requestResponse)
     open fun requestResponseConcurrent(bh: Blackhole) = concurrent(bh, 1000, ::requestResponse)
 
+    open fun requestStreamBlocking(bh: Blackhole) = blocking(bh, 100, ::requestStream)
+    open fun requestStreamParallel(bh: Blackhole) = parallel(bh, 100, ::requestStream)
+    open fun requestStreamConcurrent(bh: Blackhole) = concurrent(bh, 100, ::requestStream)
+
+    open fun requestChannelBlocking(bh: Blackhole) = blocking(bh, 10, ::requestChannel)
+    open fun requestChannelParallel(bh: Blackhole) = parallel(bh, 10, ::requestChannel)
+    open fun requestChannelConcurrent(bh: Blackhole) = concurrent(bh, 10, ::requestChannel)
 
     // operations