bridge/com.lastlock.bridge.core.planeRPC/PlaneStreamManager

PlaneStreamManager

class PlaneStreamManager(rpcChannel: RPCChannel) : PlaneStreamManagerInterface

Constructors

PlaneStreamManager

constructor(rpcChannel: RPCChannel)

Functions

attachDeviceToPlaneStream

open suspend override fun attachDeviceToPlaneStream(deviceId: Any)

open suspend override fun cancelStream()

open suspend override fun clearStream()

getActiveDevices

open override fun getActiveDevices(): List<UInt>

open override fun getStreamState(): StreamState

pushMessagesToStream

open suspend override fun pushMessagesToStream(payload: Any)

removeDeviceFromPlaneStream

open suspend override fun removeDeviceFromPlaneStream(deviceId: Any)

open suspend override fun sendTelemetry(payload: Any)

open suspend override fun startStream()

subscribeToStream

open suspend override fun subscribeToStream(handler: Any): UUID

waitForStreamConnection

suspend fun waitForStreamConnection(timeoutSeconds: Int = 30): Boolean

Wait for stream to be connected.