Concurrent Javascript

This is preliminary documentation. Full docs are coming soon.

$ npm install cjs

Examples

read/write

var cjs = require('cjs');
var channel = cjs.newChannel();
channel.read(function(value) {
	console.log('value read', value);
});
channel.write(123, function() {
	console.log('value written');
});

forever

var cjs = require('cjs');
var channel = cjs.newChannel();
(function loop() {
	channel.read(function(value) {
		console.log('value read', value);
		loop();
	});	
}());
(function loop() {
	channel.write(123, function() {
		console.log('value written');
		loop();
	});
}());

readEvent/writeEvent

var cjs = require('cjs');
var channel1 = cjs.newChannel();
var channel2 = cjs.newChannel();
cjs.select([
	channel1.readEvent(),
	channel2.readEvent()
], function(error, value) {
	console.log('value read on either channel1 or channel2', value);
});
channel1.write(1, function() {
	console.log('1 written');
});
channel2.write(2, function() {
	console.log('2 written');
});