chore: rename SourceBase.metadata to outputMetadata_

Author: silenium-dev

examples/src/main/kotlin/dev/silenium/libs/flows/examples/Simple.kt

@@ -15,18 +15,18 @@ data class MyMetadata(val negativeNumbers: Boolean)
 class MySource : SourceBase<MyData, MyMetadata>() {
     init {
         // Create two output pads, one for positive numbers and one for negative numbers
-        metadata[0u] = MyMetadata(false)
-        metadata[1u] = MyMetadata(true)
+        outputMetadata_[0u] = MyMetadata(false)
+        outputMetadata_[1u] = MyMetadata(true)
     }
 
     // Publish numbers from 0 to 100
     // Publishing can be done from any thread/coroutine, as the flow is thread-safe
     suspend fun run() {
         for (i in 0..100) {
             if (i % 2 == 0) {
-                publish(FlowItem(0u, metadata[0u]!!, MyData(i)))
+                publish(FlowItem(0u, outputMetadata_[0u]!!, MyData(i)))
             } else {
-                publish(FlowItem(1u, metadata[1u]!!, MyData(i)))
+                publish(FlowItem(1u, outputMetadata_[1u]!!, MyData(i)))
             }
         }
     }
@@ -39,7 +39,7 @@ class MyTransformer : Transformer<MyData, MyMetadata, MyData, MyMetadata>, Sourc
 
     override fun configure(pad: UInt, metadata: MyMetadata): Result<Unit> {
         inputMetadata_[pad] = metadata
-        this.metadata[pad] = metadata
+        this.outputMetadata_[pad] = metadata
         return Result.success(Unit)
     }
 

src/main/kotlin/dev/silenium/libs/flows/base/SourceBase.kt

@@ -8,14 +8,14 @@ import java.util.*
 /**
  * A base class for [Source] implementations.
  * It provides a [CloningFlow] to publish flow items.
- * It also provides a [metadata] map to store metadata for each output pad.
+ * It also provides a [outputMetadata_] map to store metadata for each output pad.
  * It implements the [Source] interface.
  * It is an [AutoCloseable] resource.
  */
 abstract class SourceBase<T, P> : Source<T, P> {
-    override val outputMetadata: Map<UInt, P> get() = metadata.toMap()
+    override val outputMetadata: Map<UInt, P> get() = outputMetadata_.toMap()
     override val flow = CloningFlow<FlowItem<T, P>>()
-    protected val metadata: MutableMap<UInt, P> = Collections.synchronizedMap(mutableMapOf<UInt, P>())
+    protected val outputMetadata_: MutableMap<UInt, P> = Collections.synchronizedMap(mutableMapOf<UInt, P>())
 
     protected suspend fun publish(item: FlowItem<T, P>) = flow.publish(item)
 

src/test/kotlin/dev/silenium/libs/flows/test/Base64Decoder.kt

@@ -31,7 +31,7 @@ class Base64Decoder : SourceBase<ByteArray, DataType>(), Transformer<Base64Buffe
     override fun configure(pad: UInt, metadata: DataType): Result<Unit> {
         check(metadata == DataType.BASE64) { "metadata must be BASE64" }
         this.inputMetadata[pad] = metadata
-        this.metadata[pad] = DataType.PLAIN
+        this.outputMetadata_[pad] = DataType.PLAIN
         return Result.success(Unit)
     }