use std::sync::{Arc, Mutex};
use std::thread;
use rs_store::{DispatchOp, StoreBuilder};
use rs_store::{Reducer, Subscriber};
#[derive(Debug, Clone)]
enum CalcAction {
Add(i32),
Subtract(i32),
}
struct CalcReducer {}
impl Default for CalcReducer {
fn default() -> CalcReducer {
CalcReducer {}
}
}
#[derive(Debug, Clone)]
struct CalcState {
count: i32,
}
impl Default for CalcState {
fn default() -> CalcState {
CalcState { count: 0 }
}
}
impl Reducer<CalcState, CalcAction> for CalcReducer {
fn reduce(&self, state: &CalcState, action: &CalcAction) -> DispatchOp<CalcState, CalcAction> {
match action {
CalcAction::Add(i) => {
println!("CalcReducer::reduce: + {}", i);
DispatchOp::Dispatch(
CalcState {
count: state.count + i,
},
vec![],
)
}
CalcAction::Subtract(i) => {
println!("CalcReducer::reduce: - {}", i);
DispatchOp::Dispatch(
CalcState {
count: state.count - i,
},
vec![],
)
}
}
}
}
struct CalcSubscriber {
id: i32,
last: Mutex<CalcState>,
}
impl Default for CalcSubscriber {
fn default() -> CalcSubscriber {
CalcSubscriber {
id: 0,
last: Mutex::new(CalcState::default()),
}
}
}
impl CalcSubscriber {
fn new(id: i32) -> CalcSubscriber {
CalcSubscriber {
id,
last: Mutex::new(CalcState::default()),
}
}
}
impl Subscriber<CalcState, CalcAction> for CalcSubscriber {
fn on_notify(&self, state: &CalcState, action: &CalcAction) {
match action {
CalcAction::Add(_i) => {
println!(
"CalcSubscriber::on_notify: id:{}, state: {:?} <- last: {:?} + action: {:?}",
self.id,
state,
self.last.lock().unwrap(),
action,
);
}
CalcAction::Subtract(_i) => {
println!(
"CalcSubscriber::on_notify: id:{}, state: {:?} <- last: {:?} + action: {:?}",
self.id,
state,
self.last.lock().unwrap(),
action,
);
}
}
*self.last.lock().unwrap() = state.clone();
}
}
pub fn main() {
println!("Hello, Concurrent!");
let store =
StoreBuilder::new_with_reducer(CalcState::default(), Box::new(CalcReducer::default()))
.with_name("store-concurrent".into())
.build()
.unwrap();
println!("add subscriber");
store.add_subscriber(Arc::new(CalcSubscriber::default())).unwrap();
let _ = store.dispatch(CalcAction::Add(1));
let store_clone = store.clone();
thread::spawn(move || {
thread::sleep(std::time::Duration::from_secs(1));
println!("add more subscriber");
store_clone.add_subscriber(Arc::new(CalcSubscriber::new(1))).unwrap();
let _ = store_clone.dispatch(CalcAction::Subtract(1));
})
.join()
.unwrap();
match store.stop() {
Ok(_) => println!("store stopped"),
Err(e) => {
panic!("store stop failed : {:?}", e);
}
}
}