mirror of
https://gitflic.ru/project/openide/openide.git
synced 2026-10-01 06:51:17 +07:00
cleanup [lsp]: optimize imports in protocolFraming.kt
GitOrigin-RevId: 47adee4c18cd8fe89486542a92d2559e0e4087e2
This commit is contained in:
committed by
intellij-monorepo-bot
parent
657a41d392
commit
097b1566e3
+4
-7
@@ -3,15 +3,11 @@ package com.jetbrains.lsp.implementation
|
||||
import com.jetbrains.lsp.protocol.LSP
|
||||
import fleet.util.decodeToStringUtf8
|
||||
import fleet.util.encodeToByteArrayUtf8
|
||||
import kotlinx.coroutines.CompletableDeferred
|
||||
import kotlinx.coroutines.CoroutineName
|
||||
import kotlinx.coroutines.CoroutineScope
|
||||
import kotlinx.coroutines.*
|
||||
import kotlinx.coroutines.channels.Channel
|
||||
import kotlinx.coroutines.channels.ReceiveChannel
|
||||
import kotlinx.coroutines.channels.SendChannel
|
||||
import kotlinx.coroutines.channels.consumeEach
|
||||
import kotlinx.coroutines.coroutineScope
|
||||
import kotlinx.coroutines.launch
|
||||
import kotlinx.io.IOException
|
||||
import kotlinx.serialization.json.JsonElement
|
||||
|
||||
@@ -74,7 +70,8 @@ private suspend fun ByteReader.readFrame(): JsonElement? {
|
||||
if (key == "Content-Length") {
|
||||
contentLength = value.toInt()
|
||||
}
|
||||
} catch(x: Throwable) {
|
||||
}
|
||||
catch (x: Throwable) {
|
||||
throw IllegalStateException("could not read header: $line", x)
|
||||
}
|
||||
}
|
||||
@@ -119,4 +116,4 @@ private suspend fun ByteWriter.writeFrame(jsonElement: JsonElement): Boolean {
|
||||
else -> throw e
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user