aurora_streams/
lib.rs

1use std::{error::Error, sync::Arc};
2
3use aurora::AuroraStreams;
4
5pub mod aurora;
6
7pub fn create_stream(
8    #[cfg(feature = "event-routing")] url: &str,
9) -> Result<&'static AuroraStreams, Box<dyn Error>> {
10    #[cfg(feature = "event-routing")]
11    let client = redis::Client::open(url)?;
12    let streams = Arc::new(AuroraStreams::new(
13        #[cfg(feature = "event-routing")]
14        client,
15    ));
16    let a_streams: &'static AuroraStreams = Box::leak(Box::new(streams.clone()));
17    Ok(a_streams)
18}