v2.0.0 Consumer

bazaartechnologies-oss · Jul 25, 2022 · 14f7486 · 14f7486
1 parent 371507f
commit 14f7486
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 17 deletions.
diff --git a/sealed-class-service-1/build.gradle b/sealed-class-service-1/build.gradle
@@ -3,7 +3,7 @@ plugins {
     id 'org.jetbrains.kotlin.jvm'
 }
 
-version = "1.0.0"
+version = "2.0.0"
 
 java {
     sourceCompatibility = JavaVersion.VERSION_1_7

diff --git a/...e-1/src/main/java/com/github/hamzaahmedkhan/sealed_class_service_1/ProfileTypeConsumer.kt b/...e-1/src/main/java/com/github/hamzaahmedkhan/sealed_class_service_1/ProfileTypeConsumer.kt
@@ -5,22 +5,22 @@ import kotlinx.coroutines.*
 import kotlinx.coroutines.flow.collectLatest
 
 
-suspend fun main() {
-    val producer: ProfileProducer = ProfileProducer()
-
-    // KAFKA dummy copy
-    GlobalScope.launch {
-        producer.state.collectLatest{ profileType ->
-            checkAllTypes(profileType)
-        }
-
-    }
-    producer.sendMeStates()
-
-
-}
-
-fun checkAllTypes(profileType: ProfileType) {
+//suspend fun main() {
+//    val producer: ProfileProducer = ProfileProducer()
+//
+//    // KAFKA dummy copy
+//    GlobalScope.launch {
+//        producer.state.collectLatest{ profileType ->
+//            checkAllTypes(profileType)
+//        }
+//
+//    }
+//    producer.sendMeStates()
+//
+//
+//}
+
+fun profileConsumer(profileType: ProfileType) {
     println(profileType)
 
     when (profileType) {