chore(modelql): replace "flow" with "stream" in all names

Author: slisson

model-server/src/main/kotlin/org/modelix/model/server/handlers/ModelReplicationServer.kt

@@ -485,7 +485,7 @@ class InMemoryMemoizationPersistence : IMemoizationPersistence {
         override fun memoize(input: IStepOutput<In>): IStepOutput<Out> {
             runSynchronized(cache) {
                 return cache.get(IndexCacheKey(normalizedQueryDescriptor, input)) {
-                    query.asFlow(QueryEvaluationContext.EMPTY, input).exactlyOne().getSynchronous()
+                    query.asStream(QueryEvaluationContext.EMPTY, input).exactlyOne().getSynchronous()
                 }.upcast()
             }
         }

modelql-client/src/commonMain/kotlin/org/modelix/modelql/client/ModelQLNode.kt

@@ -37,7 +37,7 @@ import org.modelix.modelql.core.IMonoUnboundQuery
 import org.modelix.modelql.core.IQueryExecutor
 import org.modelix.modelql.core.IUnboundQuery
 import org.modelix.modelql.core.IZip2Output
-import org.modelix.modelql.core.StepFlow
+import org.modelix.modelql.core.StepStream
 import org.modelix.modelql.core.asMono
 import org.modelix.modelql.core.asStepOutput
 import org.modelix.modelql.core.filterNotNull
@@ -72,7 +72,7 @@ abstract class ModelQLNode(val client: ModelQLClient) : INode, ISupportsModelQL,
         return this
     }
 
-    override fun <Out> createFlow(query: IUnboundQuery<INode, *, Out>): StepFlow<Out> {
+    override fun <Out> createStream(query: IUnboundQuery<INode, *, Out>): StepStream<Out> {
         return singleFromCoroutine {
             val result = when (query) {
                 is IMonoUnboundQuery<*, *> -> {

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/CollectorStep.kt

@@ -148,7 +148,7 @@ class MultimapCollectorStepOutputSerializer<K, V>(inputElementSerializer: KSeria
 class ListCollectorStep<E> : CollectorStep<E, List<E>>() {
     override fun createDescriptor(context: QueryGraphDescriptorBuilder) = Descriptor()
 
-    override fun aggregate(input: StepFlow<E>, context: IFlowInstantiationContext): Single<IStepOutput<List<E>>> {
+    override fun aggregate(input: StepStream<E>, context: IStreamInstantiationContext): Single<IStepOutput<List<E>>> {
         return input.toList().map { inputList ->
             val outputList = inputList.map { it.value }
             CollectorStepOutput(inputList, inputList, outputList)
@@ -178,7 +178,7 @@ class SetCollectorStep<E> : CollectorStep<E, Set<E>>() {
 
     override fun createDescriptor(context: QueryGraphDescriptorBuilder) = Descriptor()
 
-    override fun aggregate(input: StepFlow<E>, context: IFlowInstantiationContext): Single<IStepOutput<Set<E>>> {
+    override fun aggregate(input: StepStream<E>, context: IStreamInstantiationContext): Single<IStepOutput<Set<E>>> {
         return input.toList().map { inputAsList ->
             val inputList = ArrayList<IStepOutput<E>>()
             val outputSet = HashSet<E>()
@@ -210,7 +210,7 @@ class MapCollectorStep<K, V> : CollectorStep<IZip2Output<Any?, K, V>, Map<K, V>>
 
     override fun createDescriptor(context: QueryGraphDescriptorBuilder) = Descriptor()
 
-    override fun aggregate(input: StepFlow<IZip2Output<Any?, K, V>>, context: IFlowInstantiationContext): Single<IStepOutput<Map<K, V>>> {
+    override fun aggregate(input: StepStream<IZip2Output<Any?, K, V>>, context: IStreamInstantiationContext): Single<IStepOutput<Map<K, V>>> {
         return input.toList().map { inputAsList ->
             val inputList = ArrayList<IStepOutput<IZip2Output<Any?, K, V>>>()
             val internalMap = HashMap<K, IStepOutput<V>>()
@@ -253,7 +253,7 @@ class MultimapCollectorStep<K, V> : CollectorStep<IZip2Output<Any?, K, V>, Map<K
 
     override fun createDescriptor(context: QueryGraphDescriptorBuilder) = Descriptor()
 
-    override fun aggregate(input: StepFlow<IZip2Output<Any?, K, V>>, context: IFlowInstantiationContext): Single<IStepOutput<Map<K, List<V>>>> {
+    override fun aggregate(input: StepStream<IZip2Output<Any?, K, V>>, context: IStreamInstantiationContext): Single<IStepOutput<Map<K, List<V>>>> {
         return input.toList().map { inputAsList ->
             val inputList = ArrayList<IStepOutput<IZip2Output<Any?, K, V>>>()
             val internalMap = HashMap<K, MutableList<IStepOutput<V>>>()

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/ConstantSourceStep.kt

@@ -58,7 +58,7 @@ open class ConstantSourceStep<E>(val element: E, val type: KType) : ProducingSte
         return element
     }
 
-    override fun createFlow(context: IFlowInstantiationContext): StepFlow<E> {
+    override fun createStream(context: IStreamInstantiationContext): StepStream<E> {
         return observableOf(element.asStepOutput(this))
     }
 

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/CountingStep.kt

@@ -20,8 +20,8 @@ import kotlinx.serialization.Serializable
 import org.modelix.streams.count
 
 class CountingStep() : AggregationStep<Any?, Int>() {
-    override fun aggregate(input: StepFlow<Any?>, context: IFlowInstantiationContext): Single<IStepOutput<Int>> {
-        return input.count().asStepFlow(this)
+    override fun aggregate(input: StepStream<Any?>, context: IStreamInstantiationContext): Single<IStepOutput<Int>> {
+        return input.count().asStepStream(this)
     }
 
     override fun createDescriptor(context: QueryGraphDescriptorBuilder) = CountDescriptor()

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/DropStep.kt

@@ -24,7 +24,7 @@ class DropStep<E>(val count: Int) : TransformingStep<E, E>(), IMonoStep<E>, IFlu
 
     override fun canBeMultiple(): Boolean = getProducer().canBeMultiple()
 
-    override fun createFlow(input: StepFlow<E>, context: IFlowInstantiationContext): StepFlow<E> {
+    override fun createStream(input: StepStream<E>, context: IStreamInstantiationContext): StepStream<E> {
         return input.skip(count.toLong())
     }
 

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/EmptyStringIfNullStep.kt

@@ -31,7 +31,7 @@ class EmptyStringIfNullStep : MonoTransformingStep<String?, String>() {
         )
     }
 
-    override fun createFlow(input: StepFlow<String?>, context: IFlowInstantiationContext): StepFlow<String> {
+    override fun createStream(input: StepStream<String?>, context: IStreamInstantiationContext): StepStream<String> {
         return input.map {
             if (it.value == null) {
                 MultiplexedOutput(1, "".asStepOutput(this))

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/FilteringStep.kt

@@ -34,8 +34,8 @@ class FilteringStep<E>(val condition: MonoUnboundQuery<E, Boolean?>) : Transform
         }
     }
 
-    override fun createFlow(input: StepFlow<E>, context: IFlowInstantiationContext): StepFlow<E> {
-        return input.filterBySingle { condition.asFlow(context.evaluationContext, it).map { it.value == true }.firstOrDefault(false) }
+    override fun createStream(input: StepStream<E>, context: IStreamInstantiationContext): StepStream<E> {
+        return input.filterBySingle { condition.asStream(context.evaluationContext, it).map { it.value == true }.firstOrDefault(false) }
     }
 
     override fun getOutputSerializer(serializationContext: SerializationContext): KSerializer<out IStepOutput<E>> {

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/FirstElementStep.kt

@@ -21,7 +21,7 @@ import kotlinx.serialization.Serializable
 class FirstElementStep<E>() : MonoTransformingStep<E, E>() {
     override fun canBeMultiple(): Boolean = false
 
-    override fun createFlow(input: StepFlow<E>, context: IFlowInstantiationContext): StepFlow<E> {
+    override fun createStream(input: StepStream<E>, context: IStreamInstantiationContext): StepStream<E> {
         return input.take(1)
     }
 

modelql-core/src/commonMain/kotlin/org/modelix/modelql/core/FirstOrNullStep.kt

@@ -22,7 +22,7 @@ import kotlinx.serialization.SerialName
 import kotlinx.serialization.Serializable
 
 class FirstOrNullStep<E>() : AggregationStep<E, E?>() {
-    override fun aggregate(input: StepFlow<E>, context: IFlowInstantiationContext): Single<IStepOutput<E?>> {
+    override fun aggregate(input: StepStream<E>, context: IStreamInstantiationContext): Single<IStepOutput<E?>> {
         return input.firstOrComplete().map { MultiplexedOutput(0, it) }
             .defaultIfEmpty(MultiplexedOutput(1, null.asStepOutput(this)))
     }