zuzu-rust 0.2.0

Rust implementation of ZuzuScript
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

from test/more import *;

requires_capability( "db" );
requires_capability( "proc" );

from std/db import DB;
from std/proc import sleep_async;
from std/task import all;

let dbh := DB.temp();
dbh.prepare( "create table writes (value integer)" ).execute();
let ins := dbh.prepare( "insert into writes (value) values (?)" );

async function write_one ( v ) {
	await {
		sleep_async(0.01);
	};
	ins.execute(v);
	return v;
}

let values := await {
	all( [ write_one( 1 ), write_one( 2 ), write_one( 3 ), write_one( 4 ) ] );
};

let q := dbh.prepare( "select value from writes order by value" );
q.execute();
let rows := q.all_array();

is( values.length(), 4, "all concurrent tasks resolved" );
is( rows.length(), 4, "all concurrent writes persisted" );
is( rows[0][0], 1, "first persisted value is present" );
is( rows[3][0], 4, "last persisted value is present" );

done_testing();