Skip to content

Commit

Permalink
style: removed unused imports
Browse files Browse the repository at this point in the history
  • Loading branch information
Dennis Schröder committed Nov 12, 2021
1 parent fe01784 commit df4dbb1
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 6 deletions.
1 change: 0 additions & 1 deletion lib/src/main/kotlin/io/traxter/ktor/mqtt/Extensions.kt
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package io.traxter.ktor.mqtt
import io.ktor.application.feature
import io.ktor.routing.Route
import io.ktor.routing.application
import io.ktor.routing.route
import io.ktor.util.pipeline.ContextDsl
import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.Job
Expand Down
5 changes: 0 additions & 5 deletions lib/src/main/kotlin/io/traxter/ktor/mqtt/Plugin.kt
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ import org.eclipse.paho.mqttv5.client.MqttAsyncClient as PahoMqttClient
fun Application.Mqtt(config: Mqtt.Configuration.() -> Unit) =
install(Mqtt, config)


interface Mqtt : CoroutineScope, IMqttAsyncClient {

class Configuration {
Expand Down Expand Up @@ -138,7 +137,6 @@ internal class MqttClientPlugin(
connect(config.connectionOptions).waitForCompletion()
}


suspend fun publishMessageTo(
topic: Topic,
msg: String,
Expand All @@ -161,7 +159,6 @@ internal class MqttClientPlugin(
.await()
.also { messageListenerByTopic.remove(topic) }


override fun shutdown() {
logger.info("shutting down Mqtt")
parent.complete()
Expand All @@ -170,5 +167,3 @@ internal class MqttClientPlugin(
disconnectForcibly()
}
}


0 comments on commit df4dbb1

Please sign in to comment.