Remove try/catch

Author: aleksandar-apostolov

stream-android-core/src/main/java/io/getstream/android/core/api/StreamClient.kt

@@ -42,9 +42,6 @@ import io.getstream.android.core.api.socket.monitor.StreamHealthMonitor
 import io.getstream.android.core.api.subscribe.StreamSubscription
 import io.getstream.android.core.api.subscribe.StreamSubscriptionManager
 import io.getstream.android.core.internal.client.StreamClientImpl
-import io.getstream.android.core.internal.http.interceptor.StreamApiKeyInterceptor
-import io.getstream.android.core.internal.http.interceptor.StreamAuthInterceptor
-import io.getstream.android.core.internal.http.interceptor.StreamConnectionIdInterceptor
 import io.getstream.android.core.internal.serialization.StreamCompositeEventSerializationImpl
 import io.getstream.android.core.internal.serialization.StreamCompositeMoshiJsonSerialization
 import io.getstream.android.core.internal.serialization.StreamMoshiJsonSerializationImpl
@@ -55,7 +52,6 @@ import kotlinx.coroutines.Job
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.StateFlow
-import okhttp3.OkHttpClient
 
 /**
  * Entry point for establishing and managing a connection to Stream services.
@@ -263,13 +259,13 @@ fun StreamClient(
             httpBuilder.apply {
                 addInterceptor(StreamOkHttpInterceptors.clientInfo(clientInfoHeader))
                 addInterceptor(StreamOkHttpInterceptors.apiKey(apiKey))
-                addInterceptor(StreamOkHttpInterceptors.auth( "jwt", tokenManager, compositeSerialization))
+                addInterceptor(
+                    StreamOkHttpInterceptors.auth("jwt", tokenManager, compositeSerialization)
+                )
                 addInterceptor(StreamOkHttpInterceptors.connectionId(connectionIdHolder))
             }
         }
-        configuredInterceptors.forEach {
-            httpBuilder.addInterceptor(it)
-        }
+        configuredInterceptors.forEach { httpBuilder.addInterceptor(it) }
     }
 
     return StreamClientImpl(

stream-android-core/src/main/java/io/getstream/android/core/api/model/config/StreamHttpConfig.kt

@@ -1,3 +1,18 @@
+/*
+ * Copyright (c) 2014-2025 Stream.io Inc. All rights reserved.
+ *
+ * Licensed under the Stream License;
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    https://github.com/GetStream/stream-core-android/blob/main/LICENSE
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package io.getstream.android.core.api.model.config
 
 import okhttp3.Interceptor
@@ -13,5 +28,5 @@ import okhttp3.OkHttpClient
 data class StreamHttpConfig(
     val httpBuilder: OkHttpClient.Builder,
     val automaticInterceptors: Boolean = true,
-    val configuredInterceptors: Set<Interceptor> = emptySet()
-)
+    val configuredInterceptors: Set<Interceptor> = emptySet(),
+)

stream-android-core/src/main/java/io/getstream/android/core/internal/serialization/StreamCompositeEventSerializationImpl.kt

@@ -98,33 +98,30 @@ internal class StreamCompositeEventSerializationImpl<T>(
     fun deserialize(raw: String): Result<StreamCompositeSerializationEvent<T>> =
         runCatchingCancellable {
             val type = peekType(raw)
-            return try {
-                when (type) {
-                    null -> {
-                        val ext = external
-                        ext.deserialize(raw).map { StreamCompositeSerializationEvent.external(it) }
-                    }
-                    in alsoExternal -> {
-                        val coreSer = internal
-                        val extSer = external
-                        val core = coreSer.deserialize(raw).getOrThrow()
-                        val prod = extSer.deserialize(raw).getOrThrow()
-                        Result.success(StreamCompositeSerializationEvent.both(core, prod))
-                    }
-                    in internalTypes -> {
-                        val coreSer = internal
-                        coreSer.deserialize(raw).map {
-                            StreamCompositeSerializationEvent.internal(it)
-                        }
-                    }
-                    else -> {
-                        val ext = external
-                        ext.deserialize(raw).map { StreamCompositeSerializationEvent.external(it) }
-                    }
+            when (type) {
+                null -> {
+                    val ext = external
+                    ext.deserialize(raw).map { StreamCompositeSerializationEvent.external(it) }
                 }
-            } catch (e: Throwable) {
-                Result.failure(e)
-            }
+
+                in alsoExternal -> {
+                    val coreSer = internal
+                    val extSer = external
+                    val core = coreSer.deserialize(raw).getOrThrow()
+                    val prod = extSer.deserialize(raw).getOrThrow()
+                    Result.success(StreamCompositeSerializationEvent.both(core, prod))
+                }
+
+                in internalTypes -> {
+                    val coreSer = internal
+                    coreSer.deserialize(raw).map { StreamCompositeSerializationEvent.internal(it) }
+                }
+
+                else -> {
+                    val ext = external
+                    ext.deserialize(raw).map { StreamCompositeSerializationEvent.external(it) }
+                }
+            }.getOrThrow()
         }
 
     private fun peekType(raw: String): String? {