5 releases
0.2.0 | Nov 8, 2019 |
---|---|
0.2.0-alpha.4 | Nov 4, 2019 |
0.1.0-alpha.3 | Oct 31, 2019 |
0.0.1 |
|
#83 in #await
49KB
1K
SLoC
rustracts
Rust crate for voidable insurance contracts over a context in async/await rust
rustracts = "0.2.0"
Features
Available
- FuturesContract: Will produce a value at expiration if the contract was not voided
- OnKillContract: Will produce a value if the context is invalidated
- OptionContract: Will produce value at expiration if the secondary context has realised and the contract was not voided before
Examples
use std::time::Duration;
use crate::context::cmp::GtContext;
use crate::{ContractExt, Status, FuturesContract};
fn simple_contract() {
let context: usize = 3;
let c = FuturesContract::new(Duration::from_secs(1), context, |con| -> usize { con + 5 });
if let Status::Completed(value) = futures::executor::block_on(c) {
assert_eq!(value, 8)
} else {
assert!(false)
}
}
fn voided_contract() {
let context = GtContext(3, 2); // Context is true if self.0 > self.1
let c = FuturesContract::new(Duration::from_secs(4), context, |con| -> usize {
con.0 + 5
});
let handle = std::thread::spawn({
let mcontext = c.get_context();
move || {
(*mcontext.lock().unwrap()).0 = 1; // Modify context before contract ends
}
});
if let Status::Completed(val) = futures::executor::block_on(c) {
assert_ne!(val, 1);
} else {
assert!(true); // Contract should be voided because updated value is 1 which is < 2
}
handle.join().unwrap();
}
fn updated_contract() {
let context = GtContext(3, 2); // Context is valid if self.0 > self.1
let c = FuturesContract::new(Duration::from_secs(1), context, |con| -> usize {
con.0 + 5
});
let handle = std::thread::spawn({
let mcontext = c.get_context();
move || {
(*mcontext.lock().unwrap()).0 += 2;
}
});
if let Status::Completed(value) = futures::executor::block_on(c) {
assert_eq!(value, 10);
} else {
assert!(false);
}
handle.join().unwrap();
}
Dependencies
~1MB
~15K SLoC