Hazards

class Hazards constructor(hazardsProvider: MqttDataProvider, postDispatcher: CoroutineDispatcher = Dispatchers.Main, backgroundDispatcher: CoroutineDispatcher = Dispatchers.IO.limitedParallelism( NUMBER_OF_PARALLEL_DESERIALIZATIONS )) : AutoCloseable

Identifies hazards provider.

Important: This is a Public Preview API. It may be changed or removed at any time.

Constructors

Link copied to clipboard
constructor(hazardsProvider: MqttDataProvider, postDispatcher: CoroutineDispatcher = Dispatchers.Main, backgroundDispatcher: CoroutineDispatcher = Dispatchers.IO.limitedParallelism( NUMBER_OF_PARALLEL_DESERIALIZATIONS ))

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard