Struct InMemoryEventStreamer 

pub struct InMemoryEventStreamer { /* private fields */ }

In-memory event streamer implementation for development and testing.

InMemoryEventStreamer provides a simple, fast event streaming implementation that runs entirely in memory. It’s perfect for:

• Development and testing
• Single-process applications
• Prototyping event-driven architectures

For production use with multiple processes, consider a distributed streaming solution like Redis Streams or Apache Kafka.

Example

use eventuali_core::{InMemoryEventStreamer, SubscriptionBuilder};

let streamer = InMemoryEventStreamer::new();

let subscription = SubscriptionBuilder::new().build();
let mut receiver = streamer.subscribe(subscription).await?;

Implementations

impl InMemoryEventStreamer

pub fn new(capacity: usize) -> Self

Trait Implementations

impl EventStreamer for InMemoryEventStreamer

fn subscribe<'life0, 'async_trait>( &'life0 self, subscription: Subscription, ) -> Pin<Box<dyn Future<Output = Result<EventStreamReceiver>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn unsubscribe<'life0, 'life1, 'async_trait>( &'life0 self, subscription_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn publish_event<'life0, 'async_trait>( &'life0 self, event: Event, stream_position: u64, global_position: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_stream_position<'life0, 'life1, 'async_trait>( &'life0 self, stream_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_global_position<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,