diff --git a/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventHandlerBuilder.kt b/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventHandlerBuilder.kt index c994f93..ea07cb6 100644 --- a/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventHandlerBuilder.kt +++ b/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventHandlerBuilder.kt @@ -78,6 +78,8 @@ public suspend fun HttpClient.webSocketEvents( withRetries(onError = { logger.w { "Error opening WS session: ${it.message}" + + it.printStackTrace() } }) { webSocket( diff --git a/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventReceiver.kt b/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventReceiver.kt index f2f6873..e122a22 100644 --- a/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventReceiver.kt +++ b/ktor-ws-events-client/src/commonMain/kotlin/dev/d1s/ktor/events/client/WebSocketEventReceiver.kt @@ -46,6 +46,8 @@ public suspend inline fun DefaultClientWebSocketSession.receiveWebSo withRetries(continuous = true, onError = { EventReceiverLog.w { "Error receiving web socket events: ${it.message}" + + it.printStackTrace() } }) { val event = receiveWebSocketEvent()