chore: rename Sink.submit to receive

Author: silenium-dev

src/main/kotlin/dev/silenium/libs/flows/api/Sink.kt

@@ -18,12 +18,12 @@ interface Sink<T, P> : FlowCollector<FlowItem<T, P>>, AutoCloseable {
 
     fun configure(pad: UInt, metadata: P): Result<Unit>
 
-    suspend fun submit(item: FlowItem<T, P>): Result<Unit>
+    suspend fun receive(item: FlowItem<T, P>): Result<Unit>
 
     override suspend fun emit(value: FlowItem<T, P>) {
         check(inputMetadata.containsKey(value.pad)) { "pad not configured" }
         check(inputMetadata[value.pad] == value.metadata) { "metadata mismatch" }
 
-        submit(value).getOrThrow()
+        receive(value).getOrThrow()
     }
 }

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

@@ -35,7 +35,7 @@ class Base64Decoder : SourceBase<ByteArray, DataType>(), Transformer<Base64Buffe
         return Result.success(Unit)
     }
 
-    override suspend fun submit(item: FlowItem<Base64Buffer, DataType>): Result<Unit> = runCatching {
+    override suspend fun receive(item: FlowItem<Base64Buffer, DataType>): Result<Unit> = runCatching {
         queue.send(FlowItem(item.pad, DataType.PLAIN, item.value))
     }
 

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

@@ -15,7 +15,7 @@ class BufferSink<T, P>(vararg pads: Pair<UInt, P>) : Sink<T, P> {
     private val flow_ = MutableStateFlow<Map<UInt, List<FlowItem<T, P>>>>(emptyMap())
     val flow: StateFlow<Map<UInt, List<FlowItem<T, P>>>> = flow_.asStateFlow()
 
-    override suspend fun submit(item: FlowItem<T, P>): Result<Unit> {
+    override suspend fun receive(item: FlowItem<T, P>): Result<Unit> {
         buffer_.getOrPut(item.pad, ::mutableListOf).add(item)
         flow_.emit(buffer)
         return Result.success(Unit)