Provides an API for binding implementations of Java's Flow to subjects and channels provided by Caplin DataSource.
This library is designed for use from both Java and Kotlin.

Provides an API for binding Kotlin Coroutines, i.e. suspending functions and Flow, to subjects and channels provided by Caplin DataSource.

Provides a common API used by the datasourcex-java-flow, datasourcex-kotlin and datasourcex-reactivestreams modules.

Provides an API for binding Reactive Streams implementations such as Reactor, RxJava and Akka Streams to subjects and channels provided by Caplin DataSource.
This library is designed for use from both Java and Kotlin.

Utility classes and functions commonly used in DataSource integrations, such as efficiently observable Maps, and stream transformations.

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.