build.gradle.kts

@@ -1,10 +1,6 @@
 val kmathVersion by extra("0.1.2-dev-3")
 
 allprojects {
-//    apply(plugin = "maven")
-//    apply(plugin = "maven-publish")
-//    apply(plugin = "com.jfrog.artifactory")
-
     repositories {
         jcenter()
         maven("https://kotlin.bintray.com/kotlinx")

buildSrc/build.gradle.kts

@@ -7,7 +7,7 @@ repositories {
     jcenter()
 }
 
-val kotlinVersion = "1.3.30"
+val kotlinVersion = "1.3.31"
 
 // Add plugins used in buildSrc as dependencies, also we should specify version only here
 dependencies {

kmath-coroutines/src/jvmTest/kotlin/scientifik/kmath/streaming/BufferFlowTest.kt

@@ -1,7 +1,8 @@
 package scientifik.kmath.streaming
 
 import kotlinx.coroutines.*
-import kotlinx.coroutines.flow.*
+import kotlinx.coroutines.flow.asFlow
+import kotlinx.coroutines.flow.collect
 import org.junit.Test
 import scientifik.kmath.async
 import scientifik.kmath.collect
@@ -20,7 +21,7 @@ class BufferFlowTest {
     fun map() {
         runBlocking {
             (1..20).asFlow().map( dispatcher) {
-                println("Started $it on ${Thread.currentThread().name}")
+                //println("Started $it on ${Thread.currentThread().name}")
                 @Suppress("BlockingMethodInNonBlockingContext")
                 Thread.sleep(200)
                 it
@@ -34,7 +35,7 @@ class BufferFlowTest {
     fun async() {
         runBlocking {
             (1..20).asFlow().async(dispatcher) {
-                println("Started $it on ${Thread.currentThread().name}")
+                //println("Started $it on ${Thread.currentThread().name}")
                 @Suppress("BlockingMethodInNonBlockingContext")
                 Thread.sleep(200)
                 it