From f97567421fa9c59ae6398ce42004a23f139a46d7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E1=84=80=E1=85=B5=E1=86=B7=E1=84=92=E1=85=AD=E1=84=8B?=
 =?UTF-8?q?=E1=85=AE=5BSE=5D=5BSmartEditor=5D?= <hyowoo.kim@navercorp.com>
Date: Fri, 12 Apr 2024 10:31:17 +0900
Subject: [PATCH] fix test

---
 yorkie/src/main/kotlin/dev/yorkie/core/Client.kt | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/yorkie/src/main/kotlin/dev/yorkie/core/Client.kt b/yorkie/src/main/kotlin/dev/yorkie/core/Client.kt
index 44c30b95b..b99c1f984 100644
--- a/yorkie/src/main/kotlin/dev/yorkie/core/Client.kt
+++ b/yorkie/src/main/kotlin/dev/yorkie/core/Client.kt
@@ -1,6 +1,7 @@
 package dev.yorkie.core
 
 import androidx.annotation.VisibleForTesting
+import com.connectrpc.Code
 import com.connectrpc.ConnectException
 import com.connectrpc.ProtocolClientConfig
 import com.connectrpc.ServerOnlyStreamInterface
@@ -306,7 +307,9 @@ public class Client @VisibleForTesting internal constructor(
                             retry = 0
                         }.onFailure {
                             retry++
-                            if (retry > 3 || it is ClosedReceiveChannelException) {
+                            if (retry > 3 || it is ClosedReceiveChannelException ||
+                                (it as? ConnectException)?.code == Code.UNAVAILABLE
+                            ) {
                                 _streamConnectionStatus.emit(StreamConnectionStatus.Disconnected)
                                 stream.safeClose()
                             }