kmath-commons/build.gradle.kts

@@ -7,7 +7,7 @@ description = "Commons math binding for kmath"
 
 dependencies {
     api(project(":kmath-core"))
-    api(project(":kmath-sequential"))
+    api(project(":kmath-streaming"))
     api("org.apache.commons:commons-math3:3.6.1")
     testImplementation("org.jetbrains.kotlin:kotlin-test")
     testImplementation("org.jetbrains.kotlin:kotlin-test-junit")

kmath-commons/src/main/kotlin/scientifik/kmath/transform/Transformations.kt

@@ -2,9 +2,9 @@ package scientifik.kmath.transform
 
 import org.apache.commons.math3.transform.*
 import scientifik.kmath.operations.Complex
-import scientifik.kmath.sequential.Processor
+import scientifik.kmath.streaming.Processor
-import scientifik.kmath.sequential.Producer
+import scientifik.kmath.streaming.Producer
-import scientifik.kmath.sequential.map
+import scientifik.kmath.streaming.map
 import scientifik.kmath.structures.*
 
 

kmath-streaming/build.gradle.kts

@@ -0,0 +1,36 @@
+plugins {
+    kotlin("multiplatform")
+    id("kotlinx-atomicfu")
+}
+
+val atomicfuVersion: String by rootProject.extra
+
+kotlin {
+    jvm ()
+    js()
+
+    sourceSets {
+        val commonMain by getting {
+            dependencies {
+                api(project(":kmath-core"))
+                api(project(":kmath-coroutines"))
+                compileOnly("org.jetbrains.kotlinx:atomicfu-common:${Ver.atomicfuVersion}")
+            }
+        }
+        val jvmMain by getting {
+            dependencies {
+                compileOnly("org.jetbrains.kotlinx:atomicfu:${Ver.atomicfuVersion}")
+            }
+        }
+        val jsMain by getting {
+            dependencies {
+                compileOnly("org.jetbrains.kotlinx:atomicfu-js:${Ver.atomicfuVersion}")
+            }
+        }
+
+    }
+}
+
+atomicfu {
+    variant = "VH"
+}

kmath-streaming/src/commonMain/kotlin/scientifik/kmath/streaming/BufferStreaming.kt

@@ -1,4 +1,4 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.ExperimentalCoroutinesApi

kmath-streaming/src/commonMain/kotlin/scientifik/kmath/streaming/Chain.kt

@@ -14,7 +14,7 @@
  *  limitations under the License.
  */
 
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.atomicfu.atomic
 import kotlinx.coroutines.CoroutineScope

kmath-streaming/src/commonMain/kotlin/scientifik/kmath/streaming/Cumulative.kt

@@ -1,4 +1,4 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import scientifik.kmath.operations.Space
 import kotlin.jvm.JvmName

kmath-streaming/src/commonMain/kotlin/scientifik/kmath/streaming/RingBuffer.kt

@@ -1,4 +1,4 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.coroutines.sync.Mutex
 import kotlinx.coroutines.sync.withLock

kmath-streaming/src/commonMain/kotlin/scientifik/kmath/streaming/Streaming.kt

@@ -1,4 +1,4 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.GlobalScope

kmath-streaming/src/commonTest/kotlin/scientifik/kmath/streaming/CumulativeKtTest.kt

@@ -1,8 +1,6 @@
 package scientifik.kmath.misc
 
-import scientifik.kmath.sequential.cumulativeSum
+import scientifik.kmath.streaming.cumulativeSum
-import kotlin.test.Test
-import kotlin.test.assertEquals
 
 class CumulativeKtTest {
     @Test

kmath-streaming/src/jvmMain/kotlin/scientifik/kmath/streaming/ChainExt.kt

@@ -1,4 +1,4 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.coroutines.runBlocking
 import kotlin.sequences.Sequence

kmath-streaming/src/jvmTest/kotlin/streaming/RingBufferTest.kt

@@ -1,9 +1,7 @@
-package scientifik.kmath.sequential
+package scientifik.kmath.streaming
 
 import kotlinx.coroutines.runBlocking
 import scientifik.kmath.structures.asSequence
-import kotlin.test.Test
-import kotlin.test.assertEquals
 
 class RingBufferTest {
     @Test