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 |
Add the required dependencies to your project:
dependencies {
implementation("com.caplin.integration.datasourcex:datasourcex-<java-flow|kotlin|reactivestreams>:<version>")
}Then refer to the documentation:
This module provides a starter for integrating Caplin DataSource with your Spring Boot 3.5 application, and integration with Spring Messaging for publishing data from annotated functions.
Add the following dependency to your project:
dependencies {
implementation("com.caplin.integration.datasourcex:spring-boot-starter-datasource:<version>")
}Then refer to the documentation, hands-on tutorial and examples.