int
main (void) {
	uv_loop_t *loop = uv_default_loop();
	async(env, loop) {
		queue(env, job);
		wait(env, 500, called_500ms_later);
		interval(env, 300, every_300ms);
	}
	return uv_run(loop, UV_RUN_DEFAULT);
}

async(env, loop) {
	queue(env, job_fn);
}

async(env, loop) {
	wait(env, 500, job_fn);
}

async(env, loop) {
	interval(env, 500, job_fn);
}

static void
on_interval (async_work_data_t  *work) {
	if (++interval_count > 10) {
		printf("interval limit reached. Stopping.. \n");
		data->rc = 1;
	} else {
		printf("interval #%d\n", interval_count);
	}
}

#include "async.h"
#include <assert.h>
#include <stdlib.h>
#include <stdio.h>
#include <sys/stat.h>
staic void
on_spawn (async_work_data_t *work) {
	assert(0 == work->rc);
	assert(0 == work->signal);
	assert(work->process);
	struct stat s;
	assert(0 == stat("./foo", &s));
	assert(0 == stat("./foo/bar", &s));
	assert(0 == stat("./foo/bar/biz", &s));
}
int
main (void) {
	async(env, uv_default_loop()) {
		char *cmd[] = { "mkdir", "-p", "./foo/bar/biz" };
		spawn(env, cmd, on_spawn);
	}
	return uv_run(uv_default_loop(), UV_RUN_DEFAULT);
}