|
@@ -108,28 +108,28 @@ defmodule BPE.Test do
|
|
|
:lists.map(fn _ -> :kvs.append({:"$msg", [], [], [], [], []}, id) end, :lists.seq(1, x))
|
|
|
r = :kvs.save(:kvs.reader(id))
|
|
|
rid = KVS.reader(r, :id)
|
|
|
- t1 = :kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0))
|
|
|
-
|
|
|
+ t1 = :kvs.save(:kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0)))
|
|
|
+
|
|
|
z1 = :lists.reverse(KVS.reader(t1, :args))
|
|
|
r = :kvs.save(t1)
|
|
|
|
|
|
- t2 = :kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0))
|
|
|
+ t2 = :kvs.save(:kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0)))
|
|
|
z2 = :lists.reverse(KVS.reader(t2, :args))
|
|
|
r = :kvs.save(t2)
|
|
|
|
|
|
- t3 = :kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0))
|
|
|
+ t3 = :kvs.save(:kvs.take(KVS.reader(:kvs.load_reader(rid), args: p, dir: 0)))
|
|
|
z3 = :lists.reverse(KVS.reader(t3, :args))
|
|
|
|
|
|
KVS.reader(id: tid) = :kvs.save(KVS.reader(t3, dir: 1))
|
|
|
|
|
|
- n1 = :kvs.take(KVS.reader(:kvs.load_reader(tid), args: p, dir: 1))
|
|
|
+ n1 = :kvs.save(:kvs.take(KVS.reader(:kvs.load_reader(tid), args: p, dir: 1)))
|
|
|
nz1 = :lists.reverse(KVS.reader(n1, :args))
|
|
|
KVS.reader(id: tid) = :kvs.save(KVS.reader(n1, dir: 1))
|
|
|
-
|
|
|
- n2 = :kvs.take(KVS.reader(:kvs.load_reader(tid), args: p, dir: 1))
|
|
|
+
|
|
|
+ n2 = :kvs.save(:kvs.take(KVS.reader(:kvs.load_reader(tid), args: p, dir: 1)))
|
|
|
nz2 = :lists.reverse(KVS.reader(n2, :args))
|
|
|
r = :kvs.save(KVS.reader(n2, dir: 1))
|
|
|
- # assert :lists.reverse(z1 ++ z2 ++ z3) == :lists.reverse(nz2 ++ nz1 ++ z3)
|
|
|
+ assert :lists.reverse(z1 ++ z2 ++ z3) == :lists.reverse(nz2 ++ nz1 ++ z3)
|
|
|
end
|
|
|
|
|
|
|