Skip to content

Commit fdb7032

Browse files
committed
adding case for FileUrlConnection
1 parent 70482b7 commit fdb7032

File tree

1 file changed

+5
-10
lines changed
  • dataframe-csv/src/main/kotlin/org/jetbrains/kotlinx/dataframe/impl/io

1 file changed

+5
-10
lines changed

dataframe-csv/src/main/kotlin/org/jetbrains/kotlinx/dataframe/impl/io/ioUtils.kt

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,8 @@ package org.jetbrains.kotlinx.dataframe.impl.io
22

33
import org.jetbrains.kotlinx.dataframe.AnyFrame
44
import org.jetbrains.kotlinx.dataframe.DataFrame
5-
import org.jetbrains.kotlinx.dataframe.api.print
6-
import org.jetbrains.kotlinx.dataframe.io.read
75
import org.jetbrains.kotlinx.dataframe.io.readJson
8-
import org.jetbrains.kotlinx.dataframe.io.readJsonStr
6+
import sun.net.www.protocol.file.FileURLConnection
97
import java.io.File
108
import java.io.InputStream
119
import java.net.HttpURLConnection
@@ -18,7 +16,10 @@ internal fun isCompressed(file: File) = listOf("gz", "zip").contains(file.extens
1816
internal fun isCompressed(url: URL) = isCompressed(url.path)
1917

2018
internal fun catchHttpResponse(url: URL, body: (InputStream) -> AnyFrame): AnyFrame {
21-
val connection = url.openConnection() as HttpURLConnection
19+
val connection = url.openConnection()
20+
if (connection !is HttpURLConnection) {
21+
return connection.inputStream.use(body)
22+
}
2223
try {
2324
connection.connect()
2425
val code = connection.responseCode
@@ -36,9 +37,3 @@ internal fun catchHttpResponse(url: URL, body: (InputStream) -> AnyFrame): AnyFr
3637
connection.disconnect()
3738
}
3839
}
39-
40-
public fun main() {
41-
catchHttpResponse(URL("https://api.binance.com/api/v3/klines?symbol=BTCUSDT")) {
42-
DataFrame.readJson(it)
43-
}.print()
44-
}

0 commit comments

Comments
 (0)