PenumbraOS/sdk
1
0
Fork 0
mirror of https://github.com/PenumbraOS/sdk.git synced 2026-02-03 17:26:48 -06:00
Code Issues Packages Projects Releases Wiki Activity

Properly rethrow HTTP errors

Browse Source
This commit is contained in:
Adam Gastineau 2025-11-17 21:23:09 -08:00
parent 215825dcbb
commit e1a344b882
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
sdk/src/main/java/com/penumbraos/sdk/http/ktor/HttpClientPlugin.kt
View File

@ -20,7 +20,6 @@ import io.ktor.util.AttributeKey
import io.ktor.util.date.GMTDate
import io.ktor.utils.io.ByteChannel
import io.ktor.utils.io.InternalAPI
import io.ktor.utils.io.close
import io.ktor.utils.io.writeStringUtf8
/**
@ -91,24 +90,28 @@ class HttpClientPlugin(private val penumbraClient: PenumbraClient) {
}
is HttpStreamResponse.Complete -> {
Log.i("HttpClientPlugin", "Stream complete")
streamingByteChannel.flushAndClose()
}
is HttpStreamResponse.Error -> {
streamingByteChannel.close(RuntimeException("Stream error: ${response.message}"))
Log.e("HttpClientPlugin", "Stream error: ${response.message}")
streamingByteChannel.close()
throw RuntimeException("Stream error: ${response.message}")
}
}
}
} catch (e: Exception) {
Log.e("HttpClientPlugin", "Exception in streaming flow", e)
streamingByteChannel.close(e)
streamingByteChannel.close()
throw e
}
val headersList = mutableListOf<Pair<String, List<String>>>()
for (header in headers) {
headersList.add(Pair(header.key, listOf(header.value)))
}
HttpClientCall(
scope,
request.build(),