FlowExt

Kotlinx Coroutines Flow Extensions. Extensions to the Kotlin Flow library. Kotlin Flow extensions. Multiplatform Kotlinx Coroutines Flow Extensions. Multiplatform Extensions to the Kotlin Flow library. Multiplatform Kotlin Flow extensions. RxJS Kotlin Coroutines Flow. RxSwift Kotlin Coroutines Flow. RxJava Kotlin Coroutines Flow. RxJS Kotlin Flow. RxSwift Kotlin Flow. RxJava Kotlin Flow. RxJS Coroutines Flow. RxSwift Coroutines Flow. RxJava Coroutines Flow.

Author: Petrus Nguyễn Thái Học

API

0.x release docs: https://hoc081098.github.io/FlowExt/docs/0.x

Snapshot docs: https://hoc081098.github.io/FlowExt/docs/latest

Table of contents

• Create

  • concat
  • interval
  • neverFlow
  • range
  • timer

• Intermediate operators

  • bufferCount
  • concatWith
  • startWith
  • flatMapFirst
  • exhaustMap
  • flattenFirst
  • exhaustAll
  • mapIndexed
  • mapTo
  • materialize
  • dematerialize
  • retryWhenWithDelayStrategy
  • retryWhenWithExponentialBackoff
  • retryWithExponentialBackoff
  • takeUntil
  • throttle
  • throttleTime
  • withLatestFrom

• bufferCount (similar to RxJS bufferCount , RxJava buffer)

concat

• Similar to RxJS concat
• Similar to RxJava concat

interval

• Similar to RxJS interval

neverFlow

• Similar to RxJS NEVER

range

• ReactiveX docs: http://reactivex.io/documentation/operators/range.html
• Similar to RxJS range

timer

• ReactiveX docs: http://reactivex.io/documentation/operators/timer.html
• Similar to RxJS timer

concatWith

• Similar to RxJS concatWith
• Similar to RxJava concatWith

startWith

• Similar to RxJS startWith
• Similar to RxJava startWith

flatMapFirst / exhaustMap

• Similar to RxJS exhaustMap
• Similar to RxSwift flatMapFirst

flattenFirst / exhaustAll

• Similar to RxJS exhaustAll

mapTo

• Similar to RxJS mapTo)

materialize

• Similar to RxJS materialize
• Similar to RxJava materialize

dematerialize

• Similar to RxJS dematerialize
• Similar to RxJava dematerialize

takeUntil

• ReactiveX docs: http://reactivex.io/documentation/operators/takeuntil.html
• Similar to RxJS takeUntil

withLatestFrom

• RxMarbles: https://rxmarbles.com/#withLatestFrom
• Similar to RxJS withLatestFrom

... and more, please check out Docs 0.x/Docs snapshot.

Installation

allprojects {
  repositories {
    ...
    mavenCentral()
  }
}

Multiplatform

implementation("io.github.hoc081098:FlowExt:0.2.0")

JVM / Android only

implementation("io.github.hoc081098:FlowExt-jvm:0.2.0")

Native binaries

implementation("io.github.hoc081098:FlowExt-iosx64:0.2.0")
implementation("io.github.hoc081098:FlowExt-iosarm64:0.2.0")
implementation("io.github.hoc081098:FlowExt-iosarm32:0.2.0")
implementation("io.github.hoc081098:FlowExt-watchosx86:0.2.0")
implementation("io.github.hoc081098:FlowExt-watchosx64:0.2.0")
implementation("io.github.hoc081098:FlowExt-watchosarm64:0.2.0")
implementation("io.github.hoc081098:FlowExt-watchosarm32:0.2.0")
implementation("io.github.hoc081098:FlowExt-tvosx64:0.2.0")
implementation("io.github.hoc081098:FlowExt-tvosxarm64:0.2.0")
implementation("io.github.hoc081098:FlowExt-macosx64:0.2.0")
implementation("io.github.hoc081098:FlowExt-mingwx64:0.2.0")
implementation("io.github.hoc081098:FlowExt-linuxx64:0.2.0")

Snapshot

Snapshots of the development version are available in Sonatype's snapshots repository.

• Kotlin

allprojects {
  repositories {
    ...
    maven(url = "https://s01.oss.sonatype.org/content/repositories/snapshots/")
  }
}

dependencies {
  implementation("io.github.hoc081098:FlowExt:0.3.0-SNAPSHOT")
}

• Groovy

allprojects {
  repositories {
    ...
    maven { url "https://s01.oss.sonatype.org/content/repositories/snapshots/" }
  }
}

dependencies {
  implementation("io.github.hoc081098:FlowExt:0.3.0-SNAPSHOT")
}

License

MIT License

Copyright (c) 2021-2022 Petrus Nguyễn Thái Học