diff --git a/library/src/main/kotlin/com/connectrpc/ResponseMessage.kt b/library/src/main/kotlin/com/connectrpc/ResponseMessage.kt index 4eeb992d..c7544ded 100644 --- a/library/src/main/kotlin/com/connectrpc/ResponseMessage.kt +++ b/library/src/main/kotlin/com/connectrpc/ResponseMessage.kt @@ -89,7 +89,7 @@ fun ResponseMessage<*>.exceptionOrNull(): Throwable? { */ inline fun ResponseMessage.fold( onSuccess: (value: T) -> R, - onFailure: (exception: Throwable) -> R, + onFailure: (exception: ConnectException) -> R, ): R { return when (this) { is ResponseMessage.Success -> onSuccess(this.message) @@ -114,7 +114,7 @@ fun ResponseMessage.getOrDefault(defaultValue: T): T { * * Note, that this function rethrows any [Throwable] exception thrown by [onFailure] function. */ -inline fun ResponseMessage.getOrElse(onFailure: (exception: Throwable) -> R): R { +inline fun ResponseMessage.getOrElse(onFailure: (exception: ConnectException) -> R): R { return when (this) { is ResponseMessage.Success -> this.message is ResponseMessage.Failure -> onFailure(this.cause)