Function stream_messages 

pub async fn stream_messages(
    tx: Sender<BusMessage>,
    config: RedisMessageBusConfig,
    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 before the terminate signal is received.
• A Redis read operation returns a non-retryable error.