var rti = require('rticonnextdds-connector');

var connector = new rti.Connector("MyParticipantLibrary::Zero", "./ShapeExample.xml");
var input = connector.getInput("MySubscriber::MySquareReader");

var received_count = 0;

// Subscribe
connector.on('on_data_available',
    function () {
        input.take();
        for (i = 1; i <= input.samples.getLength(); i++) {
            if (input.infos.isValid(i)) {
                console.log(JSON.stringify(input.samples.getJSON(i)));
                received_count++;
            }
        }

    });

// Print statistics each second
setInterval(reportStats, 1000);
function reportStats() {
    console.log("Received messages count: " + received_count);
}