Kotlin Coroutines Libraries

A collection of kotlin coroutines flow based projects to create channels and flows around various infrastructure ideas.

Status

Installation

Maven

<dependencies>
    <dependency>
        <groupId>tech.figure.coroutines</groupId>
        <artifactId>ft-coroutines-core</artifactId>
        <version>${version}</version>
    </dependency>
    <dependency>
        <groupId>tech.figure.coroutines</groupId>
        <artifactId>ft-coroutines-retry</artifactId>
        <version>${version}</version>
    </dependency>
    <dependency>
        <groupId>tech.figure.coroutines</groupId>
        <artifactId>ft-coroutines-kafka</artifactId>
        <version>${version}</version>
    </dependency>
    <dependency>
        <groupId>tech.figure.coroutines</groupId>
        <artifactId>ft-coroutines-kafka-retry</artifactId>
        <version>${version}</version>
    </dependency>
</dependencies>

Gradle

Groovy

In build.gradle:

implementation 'tech.figure.coroutines:ft-coroutines-core:${version}'
implementation 'tech.figure.coroutines:ft-coroutines-retry:${version}'

implementation 'tech.figure.coroutines:ft-coroutines-kafka:${version}'
implementation 'tech.figure.coroutines:ft-coroutines-kafka-retry:${version}'

Kotlin

In build.gradle.kts:

implementation("tech.figure.coroutines", "ft-coroutines-core", version)
implementation("tech.figure.coroutines", "ft-coroutines-retry", version)

implementation("tech.figure.coroutines", "ft-coroutines-kafka", version)
implementation("tech.figure.coroutines", "ft-coroutines-kafka-retry", version)

Libraries

Coroutines-Core Contains common coroutines helper functions, such as tryMap, tryOnEach and chunked.

Coroutines-Retry Contains core retry logic.

Coroutines-Kafka Contains kafka methods and helpers.

Coroutines-Kafka-Retry Contains retry logic for kafka.