continuum_state 5.3.0

State-based persistence strategy for Continuum — aggregate adapters, fetch/persist lifecycle, and concurrency retry.

Continuum State

State-based persistence strategy for Continuum. Provides adapter-driven target persistence for backends that store full entity state (REST APIs, databases, GraphQL) rather than event streams.

Installation

dependencies:
  continuum: latest
  continuum_state: latest

dev_dependencies:
  build_runner: ^2.4.0
  continuum_generator: latest

Key Concepts

StateBasedStore

The configuration root for state-based persistence. Instead of persisting events, each target is loaded and saved through a TargetPersistenceAdapter.

import 'package:continuum_state/continuum_state.dart';
import 'continuum.g.dart';

final store = StateBasedStore(
  adapters: {User: UserApiAdapter(httpClient)},
  targets: $aggregateList,
);

final session = store.openSession();
await session.applyAsync<User>(userId, UserRegistered(...));
await session.saveChangesAsync(); // Adapter persists to backend

TargetPersistenceAdapter

Each adapter implements two methods — fetchAsync to load a target and persistAsync to save it:

class UserApiAdapter implements TargetPersistenceAdapter<User> {
  final HttpClient _client;

  UserApiAdapter(this._client);

  @override
  Future<User> fetchAsync(StreamId streamId) async {
    final response = await _client.get('/users/${streamId.value}');
    return User.fromJson(response.body);
  }

  @override
  Future<void> persistAsync(
    StreamId streamId,
    User target,
    List<Operation> pendingOperations,
  ) async {
    await _client.put('/users/${streamId.value}', body: target.toJson());
  }
}

> Note: `AggregatePersistenceAdapter` is kept as a deprecated alias for backward
> compatibility.

Exceptions

• TransientAdapterException — retriable adapter failure
• PermanentAdapterException — non-retriable adapter failure

Architecture

This package sits at Layer 2 of the Continuum architecture (alongside continuum_event_sourcing). It depends on continuum (core types) and continuum_uow (session engine).

License

MIT