DataHandler

constructor(messageFlow: Flow<DataMessage>, send: suspend (payload: ByteArray, options: DataSendOptions) -> Unit)