nautilus_infrastructure::redis::msgbus

Function stream_messages

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