diff --git a/src/repository/subscriber.rs b/src/repository/subscriber.rs index 933e80c7cb5a4793bac5f4af97aa388c6a2bdf13..04695cd9338ad88a09a80be2ddb57c55b59c56b8 100644 --- a/src/repository/subscriber.rs +++ b/src/repository/subscriber.rs @@ -19,4 +19,12 @@ impl SubscriberRepository { SUBSCRIBERS.get(product_type).unwrap().insert(subscriber_value.url.clone(), subscriber_value); return subscriber; } + + pub fn list_all (product_type: &str) -> Vec<Subscriber> { + if SUBSCRIBERS.get(product_type).is_none { + SUBSCRIBERS.insert(String::from(product_type), DashMap::new()); + }; + + return SUBSCRIBERS.get(product_type).unwrap().iter().map(|f| f.value().clone()).collect(); + } } \ No newline at end of file