sl4jx-kotlin/com.caplin.integration.streamlinkx

Package-level declarations

Types

sealed interface ContainerChange

A single change to the membership of a container subscription.

class ErrorEvent(val type: SubscriptionErrorType, val reason: ErrorReason) : Event<Nothing>

An Event reporting a subscription error, terminating the stream.

sealed interface Event<out T>

An event emitted from a subscription or channel Flow.

An Event stream carrying record field maps, as produced by StreamLinkConnection.getSubject.

class StatusEvent(val type: SubscriptionStatusType, val message: String, val fields: Map<String, String>) : Event<Nothing>

An Event reporting a subscription status change.

A coroutine- and Flow-friendly wrapper around a Caplin StreamLink connection.

Creates authenticated StreamLinkConnections to a Liberator.

class UpdateEvent<out T>(val payload: T) : Event<T>

An Event carrying a data payload — a record update, container change or deserialised value.

Suspends until the stream emits a StatusEvent with type STATUS_OK, returning it.

Keeps only UpdateEvents from the stream, unwrapping each to its payload.

Folds a stream of ContainerChanges into successive snapshots of the container's row subjects, emitting the updated list after each change.