diff options
author | Determinant <[email protected]> | 2020-06-13 15:20:39 -0400 |
---|---|---|
committer | Determinant <[email protected]> | 2020-06-13 15:20:39 -0400 |
commit | d0e8ceeb250ce362d7d9bf2c6e5c297c716259cc (patch) | |
tree | 0a2d915d2c332c73e1fb1fa1eea2608936e26da9 /examples/demo1.rs | |
parent | f02152a1c3ff0123efd2076fd9190feb81107b8e (diff) |
...
Diffstat (limited to 'examples/demo1.rs')
-rw-r--r-- | examples/demo1.rs | 8 |
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); } |