aboutsummaryrefslogtreecommitdiff
path: root/examples/demo1.rs
diff options
context:
space:
mode:
authorDeterminant <[email protected]>2020-06-13 15:20:39 -0400
committerDeterminant <[email protected]>2020-06-13 15:20:39 -0400
commitd0e8ceeb250ce362d7d9bf2c6e5c297c716259cc (patch)
tree0a2d915d2c332c73e1fb1fa1eea2608936e26da9 /examples/demo1.rs
parentf02152a1c3ff0123efd2076fd9190feb81107b8e (diff)
...
Diffstat (limited to 'examples/demo1.rs')
-rw-r--r--examples/demo1.rs8
1 files changed, 2 insertions, 6 deletions
diff --git a/examples/demo1.rs b/examples/demo1.rs
index 47d1423..0c735f8 100644
--- a/examples/demo1.rs
+++ b/examples/demo1.rs
@@ -191,13 +191,9 @@ fn test(
records: Vec<String>,
wal: &mut WALWriter<WALStoreTest>,
) -> Vec<WALRingId> {
- let records: Vec<WALBytes> = records
- .into_iter()
- .map(|s| s.into_bytes().into_boxed_slice())
- .collect();
let mut res = Vec::new();
- for r in wal.grow(&records).into_iter() {
- let ring_id = futures::executor::block_on(r).unwrap();
+ for r in wal.grow(records).into_iter() {
+ let ring_id = futures::executor::block_on(r).unwrap().1;
println!("got ring id: {:?}", ring_id);
res.push(ring_id);
}