Extensions for DataSource

Reactive

These modules provide APIs for consuming and providing data as streams implementations provided by popular libraries to DataSource subjects and channels.

Module	Supports
datasourcex-kotlin	Kotlin Flow and suspending functions
datasourcex-java-flow	Java Flow
datasourcex-reactivestreams	Reactive Streams such as: Reactor - Flux and Mono RxJava - Observable, Flowable, Single and Maybe

Usage

Add the required dependencies to your project:

dependencies {
    implementation("com.caplin.integration:datasourcex-<java-flow|kotlin|reactivestreams>:<version>")
}

Then refer to the documentation:

• datasourcex-reactivestreams
• datasourcex-kotlin
• datasourcex-java-flow

Spring

This module provides a starter for integrating Caplin DataSource with your Spring Boot application, and integration with Spring Messaging for publishing data from annotated functions.

Usage

Add the following dependency to your project:

dependencies {
    implementation("com.caplin.integration:spring-boot-starter-datasource:<version>")
}

Then refer to the documentation and the examples.