var ParseStream = require('openpixelcontrol-stream').OpcParseStream,
    net = require('net'),
    ws281x = require('rpi-ws281x-native');
 
 
var server = net.createServer(function(conn) {
    var parser = new ParseStream({
        channel: 1,
        dataFormat: ParseStream.DataFormat.UINT32_ARRAY
    });
 
    parser.on('setpixelcolors', function(data) {
        ws281x.render(data);
    });
 
    conn.pipe(parser);
});
 
ws281x.init(100);
server.listen(7890);

var ClientStream = require('openpixelcontrol-stream').OpcClientStream,
    net = require('net');
 
var NUM_LEDS = 100,
    OPC_CHANNEL = 0;
 
var client = new ClientStream();
 
// connect to openpixelcontrol-server at `192.168.1.42:7890`
var socket = net.createConnection(7890, '192.168.1.42', function() {
    client.pipe(socket);
 
    run();
});
 
function run() {
    // create a typed-array for color-data
    var data = new Uint32Array(NUM_LEDS);
 
    // setup an animation-loop at 10FPS
    setInterval(function () {
        // ... update colors in `data` ...
 
        client.setPixelColors(OPC_CHANNEL, data);
    }, 100);
}