Struct InMemoryConsumer 

pub struct InMemoryConsumer { /* private fields */ }

In-memory stream consumer for testing the bridge without external dependencies.

Implementations

impl InMemoryConsumer

pub fn new(messages: Vec<StreamMessage>) -> Self

Create a new in-memory consumer with pre-loaded messages.

pub fn empty() -> Self

Create an empty consumer.

pub fn produce(&mut self, source: &str, key: Option<&[u8]>, payload: &[u8])

Add a message to the stream.

pub fn committed_offsets(&self) -> &[StreamOffset]

Get committed offsets.

Trait Implementations

impl StreamConsumer for InMemoryConsumer

fn connect(&mut self) -> Result<(), StreamError>

Connect to the stream source.

fn subscribe(&mut self, sources: &[&str]) -> Result<(), StreamError>

Subscribe to topics/subjects/streams.

fn poll(&mut self, max: usize) -> Result<Vec<StreamMessage>, StreamError>

Poll for new messages (non-blocking).

fn commit(&mut self, offset: &StreamOffset) -> Result<(), StreamError>

Commit offset (acknowledge processing).

fn disconnect(&mut self) -> Result<(), StreamError>

Disconnect from the stream source.

fn is_connected(&self) -> bool

Check if connected.

fn metrics(&self) -> StreamConsumerMetrics

Get consumer metrics.