Upgrade to Coroutines 1.6.0

Author: akarnokd

README.md

@@ -11,7 +11,7 @@ Extensions to the Kotlin Flow library.
 
 ```groovy
 dependencies {
-    implementation "com.github.akarnokd:kotlin-flow-extensions:0.0.13"
+    implementation "com.github.akarnokd:kotlin-flow-extensions:0.0.14"
 }
 ```
 

build.gradle

@@ -6,7 +6,7 @@ buildscript {
     ext.bnd_version = '6.1.0'
     ext.license_version = '0.15.0'
     ext.vanniktech_version = '0.18.0'
-    ext.coroutines_version = '1.5.2'
+    ext.coroutines_version = '1.6.0'
 
     repositories {
         mavenCentral()

gradle.properties

@@ -1,5 +1,5 @@
 GROUP=com.github.akarnokd
-VERSION_NAME=0.0.13
+VERSION_NAME=0.0.14
 
 POM_ARTIFACT_ID=kotlin-flow-extensions
 POM_NAME=Kotlin Flow Extensions

src/main/kotlin/hu/akarnokd/kotlin/flow/UnicastSubject.kt

@@ -16,6 +16,7 @@
 
 package hu.akarnokd.kotlin.flow
 
+import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.flow.AbstractFlow
 import kotlinx.coroutines.flow.FlowCollector
 import java.util.concurrent.ConcurrentLinkedQueue
@@ -26,6 +27,7 @@ import java.util.concurrent.atomic.AtomicReference
  *
  * @param <T> the item type
  */
+@FlowPreview
 class UnicastSubject<T> : AbstractFlow<T>(), SubjectAPI<T> {
 
     companion object {

src/main/kotlin/hu/akarnokd/kotlin/flow/UnicastWorkSubject.kt

@@ -16,6 +16,7 @@
 
 package hu.akarnokd.kotlin.flow
 
+import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.flow.AbstractFlow
 import kotlinx.coroutines.flow.FlowCollector
 import java.util.concurrent.ConcurrentLinkedQueue
@@ -26,6 +27,7 @@ import java.util.concurrent.atomic.AtomicReference
  *
  * @param <T> the item type
  */
+@FlowPreview
 class UnicastWorkSubject<T> : AbstractFlow<T>(), SubjectAPI<T> {
 
     companion object {

src/main/kotlin/hu/akarnokd/kotlin/flow/impl/FlowAmbIterable.kt

@@ -9,7 +9,6 @@ import java.util.concurrent.atomic.AtomicInteger
 
 @FlowPreview
 class FlowAmbIterable<T>(private val sources: Iterable<Flow<T>>) : Flow<T> {
-    @InternalCoroutinesApi
     override suspend fun collect(collector: FlowCollector<T>) {
         val winner = AtomicInteger()
         val jobs = ConcurrentHashMap<Job, Int>()