Remove reading from stdin

eclipse-zenoh · Apr 18, 2024 · 968ab27 · 968ab27
1 parent ffd6072
commit 968ab27
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 2 deletions.
diff --git a/examples/src/main/kotlin/io.zenoh/ZPub.kt b/examples/src/main/kotlin/io.zenoh/ZPub.kt
@@ -62,6 +62,7 @@ class ZPub(private val emptyArgs: Boolean) : CliktCommand(
                         println("Declaring publisher on '$keyExpr'...")
                         session.declarePublisher(keyExpr).res().onSuccess { pub ->
                             pub.use {
+                                println("Press CTRL-C to quit...")
                                 val attachment = attachment?.let { decodeAttachment(it) }
                                 var idx = 0
                                 while (true) {

diff --git a/examples/src/main/kotlin/io.zenoh/ZPubThr.kt b/examples/src/main/kotlin/io.zenoh/ZPubThr.kt
@@ -87,9 +87,9 @@ class ZPubThr(private val emptyArgs: Boolean) : CliktCommand(
                             var count: Long = 0
                             var start = System.currentTimeMillis()
                             val number = number.toLong()
+                            println("Press CTRL-C to quit...")
                             while (true) {
                                 pub.put(value).res().getOrThrow()
-
                                 if (statsPrint) {
                                     if (count < number) {
                                         count++
@@ -100,7 +100,6 @@ class ZPubThr(private val emptyArgs: Boolean) : CliktCommand(
                                         start = System.currentTimeMillis()
                                     }
                                 }
-
                             }
                         }
                     }

diff --git a/examples/src/main/kotlin/io.zenoh/ZQueryable.kt b/examples/src/main/kotlin/io.zenoh/ZQueryable.kt
@@ -64,6 +64,7 @@ class ZQueryable(private val emptyArgs: Boolean) : CliktCommand(
                         println("Declaring Queryable")
                         session.declareQueryable(keyExpr).res().onSuccess { queryable ->
                             queryable.use {
+                                println("Press CTRL-C to quit...")
                                 queryable.receiver?.let { receiverChannel -> //  The default receiver is a Channel we can process on a coroutine.
                                     runBlocking {
                                         handleRequests(receiverChannel, keyExpr)

diff --git a/examples/src/main/kotlin/io.zenoh/ZSub.kt b/examples/src/main/kotlin/io.zenoh/ZSub.kt
@@ -54,6 +54,7 @@ class ZSub(private val emptyArgs: Boolean) : CliktCommand(
                         println("Declaring Subscriber on '$keyExpr'...")
                         session.declareSubscriber(keyExpr).bestEffort().res().onSuccess { subscriber ->
                             subscriber.use {
+                                println("Press CTRL-C to quit...")
                                 runBlocking {
                                     val receiver = subscriber.receiver!!
                                     val iterator = receiver.iterator()

diff --git a/examples/src/main/kotlin/io.zenoh/ZSubThr.kt b/examples/src/main/kotlin/io.zenoh/ZSubThr.kt
@@ -104,9 +104,11 @@ class ZSubThr(private val emptyArgs: Boolean) : CliktCommand(
                 println("Opening Session")
                 Session.open(config).onSuccess {
                     it.use { session ->
+                        println("Press CTRL-C to quit...")
                         subscriber =
                             session.declareSubscriber(keyExpr).reliable().with { listener(number) }.res().getOrThrow()
                         while (subscriber.isValid()) {/* Keep alive the subscriber until the test is done. */
+                            Thread.sleep(1000)
                         }
                     }
                 }