From 3894c597b21e620dd9a7d9da28abe7b7302735cf Mon Sep 17 00:00:00 2001
From: Oguzhan Soykan <oguzhansoykan@gmail.com>
Date: Wed, 1 May 2024 16:44:44 +0200
Subject: [PATCH] fix stovelistener for testing

---
 .../kotlin/stove/ktor/example/application/ExampleAppConsumer.kt | 2 +-
 1 file changed, 1 insertion(+), 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
index 1d4d91d8..a7639972 100644
--- 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)