fix stovelistener for testing

Trendyol · May 1, 2024 · 3894c59 · 3894c59
1 parent 2a007c2
commit 3894c59
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/ktor-example/src/main/kotlin/stove/ktor/example/application/ExampleAppConsumer.kt b/examples/ktor-example/src/main/kotlin/stove/ktor/example/application/ExampleAppConsumer.kt
@@ -23,7 +23,7 @@ class ExampleAppConsumer<K, V>(
 
   fun start() {
     job = scope.launch {
-      while (!job.isCancelled) {
+      while (isActive) {
         kafkaReceiver
           .withConsumer { consumer ->
             consumer.subscribe(topics)