Results for aggregate_streams

Abstractions for stream aggregation, we call them `Indicator` s.

Abstractions for stream aggregation, we call them `Indicator` s.

Event Sourcing and CQRS library with WASM support

Procedural macros for the Replay event sourcing library

Persistence layer for the Replay event sourcing library (PostgreSQL and in-memory backends)

Aggregate multiple streams by polling stream items in order, keeping the consumption of multiple streams in sync.

Abstractions for stream aggregation, we call them `Indicator` s.

Aggregate multiple streams of different types in a single stream with an item type that is a tuple of the incoming stream items.

Integration tests for es-replay-macros

A reactive stream processing library with ordered semantics, friendly interface, bullet-proof test coverage, state-of-the art documentation and examples

Unofficial, minimal async OpenAI API client for Rust with support for Chat Completions, Embeddings, Responses API, and tool calling.

CQRS/ES framework for Rust using Plain Old Rust Structs — append-only events, replay, snapshots, outbox, service bus, and pluggable infrastructure