PostsSystem/core
1
0
Fork 0
Code Issues Pull Requests1 Projects Releases Wiki Activity

optimize imports

Browse Source
This commit is contained in:
InsanusMokrassar
2020-08-15 15:26:46 +06:00
parent 7d2b1772bb
commit b3133cec77
17 changed files with 14 additions and 44 deletions
core
exposed
src
test
kotlin
com
insanusmokrassar
postssystem
core
exposed
ExposedPostsRepoCommonTests.kt
ktor
client
src
commonMain
kotlin
com
insanusmokrassar
postssystem
core
ktor
client
content
WriteContentRepoKtorClient.kt
post
WritePostsRepoKtorClient.kt
server
src
main
kotlin
com
insanusmokrassar
postssystem
core
ktor
server
content
ReadContentRepoRoutingConfigurator.ktWriteContentRepoRoutingConfigurator.kt
post
ReadPostsRepoRoutingConfigurator.ktWritePostsRepoRoutingConfigurator.kt
ktor
client
src
commonMain
kotlin
com
insanusmokrassar
postssystem
ktor
client
FlowsWebsockets.ktStandardHttpClientGetPost.kt
server
src
jvmMain
kotlin
com
insanusmokrassar
postssystem
ktor
server
FlowsWebsocket.ktServerRoutingShortcuts.kt
markups
commons
src
commonMain
kotlin
com
insanusmokrassar
postssystem
markups
core
AbstractMarkupPlugin.ktMarkupPlugin.ktMarkupsSystem.kt
html
src
jsMain
kotlin
com
insanusmokrassar
postssystem
markups
html
HtmlMarkupPlugin.kt
jvmMain
kotlin
com
insanusmokrassar
postssystem
markups
html
HtmlMarkupPlugin.kt
publishing/api/src/commonMain/kotlin/com/insanusmokrassar/postssystem/core/publishing
PublishingTrigger.kt

8
ktor/client/src/commonMain/kotlin/com/insanusmokrassar/postssystem/ktor/client/FlowsWebsockets.kt

@ -1,11 +1,13 @@
package com.insanusmokrassar.postssystem.ktor.client
import com.insanusmokrassar.postssystem.ktor.*
import com.insanusmokrassar.postssystem.ktor.asCorrectWebSocketUrl
import com.insanusmokrassar.postssystem.utils.common.safely
import io.ktor.client.HttpClient
import io.ktor.client.features.websocket.ws
import io.ktor.http.cio.websocket.*
import kotlinx.coroutines.flow.*
import io.ktor.http.cio.websocket.Frame
import io.ktor.http.cio.websocket.readBytes
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.channelFlow
/**
* @param checkReconnection This lambda will be called when it is required to reconnect to websocket to establish

3
ktor/client/src/commonMain/kotlin/com/insanusmokrassar/postssystem/ktor/client/StandardHttpClientGetPost.kt

@ -4,7 +4,8 @@ import com.insanusmokrassar.postssystem.ktor.standardKtorSerialFormat
import io.ktor.client.HttpClient
import io.ktor.client.request.get
import io.ktor.client.request.post
import kotlinx.serialization.*
import kotlinx.serialization.DeserializationStrategy
import kotlinx.serialization.SerializationStrategy
typealias BodyPair<T> = Pair<SerializationStrategy<T>, T>

3
ktor/server/src/jvmMain/kotlin/com/insanusmokrassar/postssystem/ktor/server/FlowsWebsocket.kt

@ -1,10 +1,9 @@
package com.insanusmokrassar.postssystem.ktor.server
import com.insanusmokrassar.postssystem.ktor.*
import com.insanusmokrassar.postssystem.ktor.CorrectCloseException
import com.insanusmokrassar.postssystem.utils.common.safely
import io.ktor.http.cio.websocket.*
import io.ktor.routing.Route
import io.ktor.routing.route
import io.ktor.websocket.webSocket
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.collect

1
ktor/server/src/jvmMain/kotlin/com/insanusmokrassar/postssystem/ktor/server/ServerRoutingShortcuts.kt

@ -2,7 +2,6 @@ package com.insanusmokrassar.postssystem.ktor.server
import com.insanusmokrassar.postssystem.ktor.standardKtorSerialFormat
import io.ktor.application.ApplicationCall
import io.ktor.application.call
import io.ktor.http.HttpStatusCode
import io.ktor.response.respond
import io.ktor.response.respondBytes