Continuum Store Memory

In-memory EventStore implementation for continuum. Events are stored in memory and lost when the application exits.

Installation

dependencies:
  continuum: ^0.1.0
  continuum_store_memory: ^0.1.0

Usage

import 'package:continuum/continuum.dart';
import 'package:continuum_store_memory/continuum_store_memory.dart';
import 'continuum.g.dart'; // Generated

void main() async {
  final store = EventSourcingStore(
    eventStore: InMemoryEventStore(),
    aggregates: $aggregateList,
  );

  // Use your aggregates
  final userId = StreamId('user-1');
  final session = store.openSession();
  session.startStream<User>(userId, UserRegistered(userId, 'Alice', 'alice@example.com'));
  await session.saveChangesAsync();

  final readSession = store.openSession();
  final user = await readSession.loadAsync<User>(userId);
}

When to Use

Good for:

• Unit tests and integration tests
• Development and prototyping
• Demos and examples
• Short-lived processes

Not suitable for:

• Production applications (data is not persisted)
• Long-running applications that need durability

For production, use continuum_store_hive or implement your own EventStore.

API

InMemoryEventStore()

Creates a new in-memory event store.

final eventStore = InMemoryEventStore();

All events are stored in memory and will be lost when the instance is garbage collected or the application exits.

Example

See example/lib/main.dart for a complete example.

License

MIT