mqtt-protocol/it.unibo.pulvreakt.mqtt/MqttProtocol

MqttProtocol

expect class MqttProtocol(host: String = "localhost", port: Int = 1883, username: String? = null, password: String? = null, coroutineDispatcher: CoroutineDispatcher = Dispatchers.Default, serverKeepAlive: Int = 10, retain: Boolean = true, qos: Int = 2) : Protocol

Represents the MQTT protocol used in PulvReAKt.

actual class MqttProtocol(host: String, port: Int, username: String?, password: String?, coroutineDispatcher: CoroutineDispatcher, serverKeepAlive: Int, retain: Boolean, qos: Int) : Protocol

MQTT Protocol implementation on JS side.

actual class MqttProtocol(host: String, port: Int, username: String?, password: String?, coroutineDispatcher: CoroutineDispatcher, serverKeepAlive: Int, retain: Boolean, qos: Int) : Protocol

MQTT Protocol implementation on Native and JVM side.

Constructors

Link copied to clipboard
expect constructor(host: String = "localhost", port: Int = 1883, username: String? = null, password: String? = null, coroutineDispatcher: CoroutineDispatcher = Dispatchers.Default, serverKeepAlive: Int = 10, retain: Boolean = true, qos: Int = 2)
actual constructor(host: String, port: Int, username: String?, password: String?, coroutineDispatcher: CoroutineDispatcher, serverKeepAlive: Int, retain: Boolean, qos: Int)
actual constructor(host: String, port: Int, username: String?, password: String?, coroutineDispatcher: CoroutineDispatcher, serverKeepAlive: Int, retain: Boolean, qos: Int)

Properties

Link copied to clipboard
abstract val di: DI
open lateinit override var di: DI
open lateinit override var di: DI
diContext
Link copied to clipboard
open val diContext: DIContext<*>
open val diContext: DIContext<*>
open val diContext: DIContext<*>
diTrigger
Link copied to clipboard
open val diTrigger: DITrigger?
open val diTrigger: DITrigger?
open val diTrigger: DITrigger?

Functions

Link copied to clipboard
abstract suspend fun finalize(): Either<ProtocolError, Unit>
open suspend override fun finalize(): Either<ProtocolError, Unit>
open suspend override fun finalize(): Either<ProtocolError, Unit>
Link copied to clipboard
abstract suspend fun initialize(): Either<ProtocolError, Unit>
open suspend override fun initialize(): Either<ProtocolError, Unit>
open suspend override fun initialize(): Either<ProtocolError, Unit>
Link copied to clipboard
abstract fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
open override fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
open override fun readFromChannel(from: Entity, to: Entity): Either<ProtocolError, Flow<ByteArray>>
Link copied to clipboard
abstract suspend fun setupChannel(source: Entity, destination: Entity)
open suspend override fun setupChannel(source: Entity, destination: Entity)
open suspend override fun setupChannel(source: Entity, destination: Entity)
Link copied to clipboard
abstract fun setupInjector(kodein: DI)
open override fun setupInjector(kodein: DI)
open override fun setupInjector(kodein: DI)
Link copied to clipboard
abstract suspend fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>
open suspend override fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>
open suspend override fun writeToChannel(from: Entity, to: Entity, message: ByteArray): Either<ProtocolError, Unit>