Update jars

Author: pambrose

src/main/kotlin/org/athenian/kotlin_helloworld/withCR/HelloWorldClient.kt

@@ -1,8 +1,8 @@
 package org.athenian.kotlin_helloworld.withCR
 
+import io.grpc.ConnectivityState
 import io.grpc.ManagedChannel
 import io.grpc.ManagedChannelBuilder
-import kotlinx.coroutines.coroutineScope
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.runBlocking
@@ -14,6 +14,7 @@ import org.athenian.kotlin_helloworld.msgs.Msgs.helloRequest
 import java.io.Closeable
 import java.util.concurrent.TimeUnit
 import kotlin.random.Random
+import kotlin.time.Duration.Companion.milliseconds
 
 // https://github.com/GoogleCloudPlatform/kotlin-samples/blob/master/run/grpc-hello-world-streaming/src/main/kotlin/io/grpc/examples/helloworld/HelloWorldClient.kt
 
@@ -23,52 +24,56 @@ class HelloWorldClient internal constructor(private val channel: ManagedChannel)
 
     private val stub = GreeterCoroutineStub(channel)
 
-    suspend fun sayHello(name: String) =
-        coroutineScope {
-            val request = helloRequest { this.name = name }
-            val response = stub.sayHello(request)
-            println("sayHello response: ${response.message}")
+    init {
+        with(channel) {
+            notifyWhenStateChanged(ConnectivityState.CONNECTING) { println("Connecting: ${getState(false)}") }
+            notifyWhenStateChanged(ConnectivityState.READY) { println("Ready: ${getState(false)}") }
+            notifyWhenStateChanged(ConnectivityState.IDLE) { println("Idle: ${getState(false)}") }
         }
+    }
 
-    suspend fun sayHelloWithManyRequests(name: String) =
-        coroutineScope {
-            val requests =
-                flow {
-                    repeat(5) {
-                        val request = helloRequest { this.name = "$name-$it" }
-                        emit(request)
-                    }
+    suspend fun sayHello(name: String) {
+        val request = helloRequest { this.name = name }
+        val response = stub.sayHello(request)
+        println("sayHello response: ${response.message}")
+    }
+
+    suspend fun sayHelloWithManyRequests(name: String) {
+        val requests =
+            flow {
+                repeat(5) {
+                    val request = helloRequest { this.name = "$name-$it" }
+                    emit(request)
                 }
-            val response = stub.sayHelloWithManyRequests(requests)
-            println("sayHelloWithManyRequests() response: ${response.message}")
-        }
+            }
+        val response = stub.sayHelloWithManyRequests(requests)
+        println("sayHelloWithManyRequests() response: ${response.message}")
+    }
 
-    suspend fun sayHelloWithManyReplies(name: String) =
-        coroutineScope {
-            val request = helloRequest { this.name = name }
-            val replies = stub.sayHelloWithManyReplies(request)
-            println("sayHelloWithManyReplies() replies:")
-            replies.collect { reply -> println(reply.message) }
-            println()
-        }
+    suspend fun sayHelloWithManyReplies(name: String) {
+        val request = helloRequest { this.name = name }
+        val replies = stub.sayHelloWithManyReplies(request)
+        println("sayHelloWithManyReplies() replies:")
+        replies.collect { reply -> println(reply.message) }
+        println()
+    }
 
-    suspend fun sayHelloWithManyRequestsAndReplies(name: String) =
-        coroutineScope {
-            val requests =
-                flow {
-                    repeat(5) {
-                        delay(Random.nextLong(1_000))
-                        val request = HelloRequest(name = "$name-$it")
-                        println("sayHelloWithManyRequestsAndReplies() request: $request")
-                        emit(request.toProto())
-                    }
+    suspend fun sayHelloWithManyRequestsAndReplies(name: String) {
+        val requests =
+            flow {
+                repeat(5) {
+                    delay(Random.nextLong(1_000).milliseconds)
+                    val request = HelloRequest(name = "$name-$it")
+                    println("sayHelloWithManyRequestsAndReplies() request: $request")
+                    emit(request.toProto())
                 }
-            val replies = stub.sayHelloWithManyRequestsAndReplies(requests)
-            replies.collect {
-                delay(Random.nextLong(1_000))
-                println("sayHelloWithManyRequestsAndReplies() response: ${it.toDataClass()}")
             }
+        val replies = stub.sayHelloWithManyRequestsAndReplies(requests)
+        replies.collect {
+            delay(Random.nextLong(1_000).milliseconds)
+            println("sayHelloWithManyRequestsAndReplies() response: ${it.toDataClass()}")
         }
+    }
 
     override fun close() {
         channel.shutdown().awaitTermination(5, TimeUnit.SECONDS)
@@ -79,17 +84,17 @@ class HelloWorldClient internal constructor(private val channel: ManagedChannel)
         fun main(args: Array<String>) {
             val name = if (args.isNotEmpty()) args[0] else "world"
 
-            HelloWorldClient("localhost")
-                .use { client ->
-                    runBlocking {
+            runBlocking {
+                HelloWorldClient("localhost")
+                    .use { client ->
                         with(client) {
                             sayHello(name)
                             sayHelloWithManyRequests(name)
                             sayHelloWithManyReplies(name)
                             sayHelloWithManyRequestsAndReplies(name)
                         }
                     }
-                }
+            }
         }
     }
 }

src/main/kotlin/org/athenian/kotlin_helloworld/withoutCR/HelloWorldClient.kt

@@ -12,7 +12,6 @@ import java.io.Closeable
 import java.util.concurrent.CountDownLatch
 import java.util.concurrent.TimeUnit
 
-
 class HelloWorldClient internal constructor(private val channel: ManagedChannel) : Closeable {
     constructor(host: String, port: Int = 50051) :
         this(ManagedChannelBuilder.forAddress(host, port).usePlaintext().build())