Function stream_messages

pub async fn stream_messages(
    tx: Sender<BusMessage>,
    config: DatabaseConfig,
    stream_keys: Vec<String>,
    stream_signal: Arc<AtomicBool>,
) -> Result<()>

Streams messages from Redis streams and sends them over the provided tx channel.

Errors

Returns an error if:

• Establishing the Redis connection fails.
• Any Redis read operation fails.