build.gradle.kts

@@ -7,7 +7,6 @@ plugins {
 }
 
 val dataforgeVersion: String by extra("0.6.2")
-val visionforgeVersion by extra("0.3.0-dev-10")
 val ktorVersion: String by extra(space.kscience.gradle.KScienceVersions.ktorVersion)
 val rsocketVersion by extra("0.15.4")
 val xodusVersion by extra("2.0.1")

controls-core/src/commonMain/kotlin/space/kscience/controls/spec/DeviceSpec.kt

@@ -12,7 +12,7 @@ import kotlin.reflect.KMutableProperty1
 import kotlin.reflect.KProperty
 import kotlin.reflect.KProperty1
 
-public object UnitMetaConverter : MetaConverter<Unit> {
+public object UnitMetaConverter: MetaConverter<Unit>{
     override fun metaToObject(meta: Meta): Unit = Unit
 
     override fun objectToMeta(obj: Unit): Meta = Meta.EMPTY
@@ -127,8 +127,7 @@ public abstract class DeviceSpec<D : Device> {
         PropertyDelegateProvider { _: DeviceSpec<D>, property: KProperty<*> ->
             val propertyName = name ?: property.name
             val deviceProperty = object : WritableDevicePropertySpec<D, T> {
-                override val descriptor: PropertyDescriptor = PropertyDescriptor(propertyName, writable = true)
+                override val descriptor: PropertyDescriptor = PropertyDescriptor(propertyName).apply(descriptorBuilder)
-                    .apply(descriptorBuilder)
                 override val converter: MetaConverter<T> = converter
 
                 override suspend fun read(device: D): T? = withContext(device.coroutineContext) { device.read() }

demo/all-things/src/main/kotlin/space/kscience/controls/demo/demoDeviceServer.kt

@@ -57,15 +57,15 @@ fun CoroutineScope.startDemoDeviceServer(magixEndpoint: MagixEndpoint): Applicat
     //share subscription to a parse message only once
     val subscription = magixEndpoint.subscribe(DeviceManager.magixFormat).shareIn(this, SharingStarted.Lazily)
 
-    val sinFlow = subscription.mapNotNull { (_, payload) ->
+    val sinFlow = subscription.mapNotNull {  (_, payload) ->
         (payload as? PropertyChangedMessage)?.takeIf { it.property == DemoDevice.sin.name }
     }.map { it.value }
 
-    val cosFlow = subscription.mapNotNull { (_, payload) ->
+    val cosFlow = subscription.mapNotNull {  (_, payload) ->
         (payload as? PropertyChangedMessage)?.takeIf { it.property == DemoDevice.cos.name }
     }.map { it.value }
 
-    val sinCosFlow = subscription.mapNotNull { (_, payload) ->
+    val sinCosFlow = subscription.mapNotNull {  (_, payload) ->
         (payload as? PropertyChangedMessage)?.takeIf { it.property == DemoDevice.coordinates.name }
     }.map { it.value }