All modules:

Link copied to clipboard

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.

Link copied to clipboard

Kotest test support for sl4jx-kotlin clients: a MountableExtension that runs a Caplin Liberator inside a Testcontainers container for the lifetime of a spec.

Link copied to clipboard

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

Link copied to clipboard

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

Link copied to clipboard

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.

Link copied to clipboard

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

Link copied to clipboard

Provides a Kotlin Flow-based client for consuming data from a Caplin Liberator, wrapping the StreamLink and KeyMaster SDKs.

Link copied to clipboard

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.