| Crates.io | rustracts |
| lib.rs | rustracts |
| version | 0.2.0 |
| created_at | 2019-10-30 15:13:22.086056+00 |
| updated_at | 2019-11-08 12:12:27.144672+00 |
| description | Rust crate for cancellable time based contracts in async/await |
| homepage | https://github.com/hyyking/rustracts |
| repository | https://github.com/hyyking/rustracts |
| max_upload_size | |
| id | 176949 |
| size | 28,383 |
Rust crate for voidable insurance contracts over a context in async/await rust
rustracts = "0.2.0"
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();
}