feat: introduce toThingDescription extension method

example/coaps_readproperty.dart

@@ -61,7 +61,7 @@ Future<void> main(List<String> args) async {
     },
   };
 
-  final thingDescription = ThingDescription.fromJson(thingDescriptionJson);
+  final thingDescription = thingDescriptionJson.toThingDescription();
   final consumedThing = await wot.consume(thingDescription);
   final status = await consumedThing.readProperty("status");
   final value = await status.value();

example/complex_example.dart

@@ -103,7 +103,7 @@ Future<void> main() async {
   );
   final wot = await servient.start();
 
-  final thingDescription = ThingDescription.fromJson(thingDescriptionJson);
+  final thingDescription = thingDescriptionJson.toThingDescription();
   final consumedThing = await wot.consume(thingDescription);
   final status = await consumedThing.readProperty("status");
   final value1 = await status.value();

example/http_basic_authentication.dart

@@ -67,7 +67,7 @@ Future<void> main(List<String> args) async {
   );
   final wot = await servient.start();
 
-  final thingDescription = ThingDescription.fromJson(thingDescriptionJson);
+  final thingDescription = thingDescriptionJson.toThingDescription();
   final consumedThing = await wot.consume(thingDescription);
   final status = await consumedThing.readProperty("status");
 

example/mqtt_example.dart

@@ -67,7 +67,7 @@ Future<void> main(List<String> args) async {
 
   final wot = await servient.start();
 
-  final thingDescription = ThingDescription.fromJson(thingDescriptionJson);
+  final thingDescription = thingDescriptionJson.toThingDescription();
   final consumedThing = await wot.consume(thingDescription);
   await consumedThing.readAndPrintProperty("status");
 

lib/src/core/wot.dart

@@ -136,7 +136,7 @@ class WoT implements scripting_api.WoT {
 
     final thingDescriptionStream = Stream.fromIterable(
       rawThingDescriptions.whereType<Map<String, Object?>>(),
-    ).toThingDescriptionStream();
+    ).map((rawThingDescription) => rawThingDescription.toThingDescription());
 
     return ThingDiscoveryProcess(thingDescriptionStream, filter);
   }
@@ -162,38 +162,3 @@ extension _DirectoryValidationExtension on ThingDescription {
         atTypes.contains(type);
   }
 }
-
-extension _DirectoryTdDeserializationExtension on Stream<Map<String, Object?>> {
-  Stream<ThingDescription> toThingDescriptionStream() {
-    const streamTransformer = StreamTransformer(_transformerMethod);
-
-    return transform(streamTransformer);
-  }
-
-  static StreamSubscription<ThingDescription> _transformerMethod(
-    Stream<Map<String, dynamic>> rawThingDescriptionStream,
-    bool cancelOnError,
-  ) {
-    final streamController = StreamController<ThingDescription>();
-
-    final streamSubscription = rawThingDescriptionStream.listen(
-      (rawThingDescription) {
-        try {
-          streamController.add(ThingDescription.fromJson(rawThingDescription));
-        } on Exception catch (exception) {
-          streamController.addError(exception);
-        }
-      },
-      onDone: streamController.close,
-      onError: streamController.addError,
-      cancelOnError: cancelOnError,
-    );
-
-    streamController
-      ..onPause = streamSubscription.pause
-      ..onResume = streamSubscription.resume
-      ..onCancel = streamSubscription.cancel;
-
-    return streamController.stream.listen(null);
-  }
-}

lib/src/definitions/thing_description.dart

@@ -252,3 +252,11 @@ class ThingDescription {
     return id ?? base?.toString() ?? title;
   }
 }
+
+/// Extension for generating [ThingDescription]s from [Map]s more easily.
+extension ToThingDescription on Map<String, dynamic> {
+  /// Tries to generate a [ThingDescription] from this [Map] object.
+  ThingDescription toThingDescription() {
+    return ThingDescription.fromJson(this);
+  }
+}