stream-example.js

/*global ReadableStream*/

(function () {
    'use strict';

    var interval;

    var stream = new ReadableStream({
        start: function (controller) {

            interval = setInterval(function () {
                var num = Math.random();

                controller.enqueue(num);

                if (num > 0.9) {
                    controller.close();
                    clearInterval(interval);
                }
            }, 1000);
        },
        cancel: function () {
            clearInterval(interval);
        }
    });

    console.log(stream);

}());