optimize imports
This commit is contained in:
parent
a6a7634076
commit
f31631c08f
@ -5,7 +5,6 @@ import com.insanusmokrassar.postssystem.core.publishing.TriggerControlKey
|
|||||||
import com.insanusmokrassar.postssystem.core.publishing.repos.PublishingKeysRepo
|
import com.insanusmokrassar.postssystem.core.publishing.repos.PublishingKeysRepo
|
||||||
import org.jetbrains.exposed.sql.*
|
import org.jetbrains.exposed.sql.*
|
||||||
import org.jetbrains.exposed.sql.transactions.experimental.newSuspendedTransaction
|
import org.jetbrains.exposed.sql.transactions.experimental.newSuspendedTransaction
|
||||||
import org.jetbrains.exposed.sql.transactions.transaction
|
|
||||||
|
|
||||||
class ExposedPublishingKeysRepo(
|
class ExposedPublishingKeysRepo(
|
||||||
private val database: Database
|
private val database: Database
|
||||||
|
@ -6,7 +6,8 @@ import com.insanusmokrassar.postssystem.core.post.repo.PostsRepo
|
|||||||
import com.insanusmokrassar.postssystem.core.publishing.repos.PublishingKeysRepo
|
import com.insanusmokrassar.postssystem.core.publishing.repos.PublishingKeysRepo
|
||||||
import kotlinx.coroutines.channels.BroadcastChannel
|
import kotlinx.coroutines.channels.BroadcastChannel
|
||||||
import kotlinx.coroutines.channels.Channel
|
import kotlinx.coroutines.channels.Channel
|
||||||
import kotlinx.coroutines.flow.*
|
import kotlinx.coroutines.flow.Flow
|
||||||
|
import kotlinx.coroutines.flow.asFlow
|
||||||
|
|
||||||
interface PublishingTrigger {
|
interface PublishingTrigger {
|
||||||
val postingTriggeredFlow: Flow<RegisteredPost>
|
val postingTriggeredFlow: Flow<RegisteredPost>
|
||||||
|
Loading…
Reference in New Issue
Block a user