update test based on readResolve working

wowselim · Nov 20, 2023 · 56729d4 · 56729d4
1 parent 51a22a4
commit 56729d4
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/test/src/test/java/co/selim/ebservice/test/ClusteredCustomCodecTest.kt b/test/src/test/java/co/selim/ebservice/test/ClusteredCustomCodecTest.kt
@@ -13,7 +13,6 @@ import kotlinx.coroutines.flow.launchIn
 import kotlinx.coroutines.flow.onEach
 import kotlinx.coroutines.runBlocking
 import org.junit.jupiter.api.Assertions.assertEquals
-import org.junit.jupiter.api.Assertions.assertNotEquals
 import org.junit.jupiter.api.Test
 import java.io.Serializable
 
@@ -93,7 +92,7 @@ class ClusteredCustomCodecTest {
 
       assertEquals(WeatherService.WeatherReport.Success("Sunny"), weatherChannel.receive())
       assertEquals(WeatherService.WeatherReport.Failure("Unknown city 'Berlin'"), weatherChannel.receive())
-      assertNotEquals(WeatherService.WeatherBalloon, objectChannel.receive())
+      assertEquals(WeatherService.WeatherBalloon, objectChannel.receive())
     } finally {
       serviceVertx?.run { close().coAwait() }
       consumerVertx?.run { close().coAwait() }