Options for appending events.

Options for consuming events.

A single event in the event log.

A batch of events delivered to a consumer.

Event log wrapper with Task/Stream semantics for event-sourced systems.

Low-level adapter interface for event log implementations.

Error thrown when an append operation fails.

Error thrown when closing an event log connection fails.

Error thrown when committing a cursor fails.

Error thrown when an event log connection cannot be established.

Factory for creating event log connections.

Error thrown when consuming events fails.

Error thrown when getting a cursor fails.

Configuration options for event log implementations.

Creates an in-memory event log connector for testing and development.

Configuration options for in-memory event log.

The entry point for creating a Stream. Wraps an async generator so that yielded values become success results and any thrown error becomes a single error result.

A TypeScript library that provides a powerful and flexible way to handle errors in asynchronous streams. It allows you to collect and manage errors alongside successful values in a stream, enabling you to process data while gracefully handling any issues that may arise.

A single async task with error-aware utilities like retries and timeouts.