treat completed as connected for ice connection state (#21)

@@ -11,6 +11,7 @@ import io.livekit.android.room.util.*
 import io.livekit.android.util.CloseableCoroutineScope
 import io.livekit.android.util.CloseableCoroutineScope
 import io.livekit.android.util.Either
 import io.livekit.android.util.Either
 import io.livekit.android.util.LKLog
 import io.livekit.android.util.LKLog
+import io.livekit.android.webrtc.isConnected
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.delay
@@ -324,7 +325,7 @@ internal constructor(
             return
             return
         }
         }
 
 
-        if (this.publisher.peerConnection.iceConnectionState() == PeerConnection.IceConnectionState.CONNECTED) {
+        if (this.publisher.peerConnection.isConnected()) {
             return
             return
         }
         }
 
 
@@ -334,7 +335,7 @@ internal constructor(
         // wait until publisher ICE connected
         // wait until publisher ICE connected
         val endTime = SystemClock.elapsedRealtime() + MAX_ICE_CONNECT_TIMEOUT_MS;
         val endTime = SystemClock.elapsedRealtime() + MAX_ICE_CONNECT_TIMEOUT_MS;
         while (SystemClock.elapsedRealtime() < endTime) {
         while (SystemClock.elapsedRealtime() < endTime) {
-            if (this.publisher.peerConnection.iceConnectionState() == PeerConnection.IceConnectionState.CONNECTED) {
+            if (this.publisher.peerConnection.isConnected()) {
                 return
                 return
             }
             }
             delay(50)
             delay(50)

+package io.livekit.android.webrtc
+
+import org.webrtc.PeerConnection
+
+/**
+ * Completed state is a valid state for a connected connection, so this should be used
+ * when checking for a connected state
+ */
+internal fun PeerConnection.isConnected(): Boolean {
+    return when (iceConnectionState()) {
+        PeerConnection.IceConnectionState.CONNECTED,
+        PeerConnection.IceConnectionState.COMPLETED -> true
+        else -> false
+    }
+}