var Observable = require("prescription").Observable;
 
// Create an Observable (read stream)
var observable = new Observable();
 
// This function applies a bunch of Transformers to the supplied
// Observable and returns a new Observable
var queryStream = function(observable) {
    return observable.where(function(item) { return item % 2 == 0; })
                     .skip(30)
                     .take(15)
                     .map(function(item) { return item * 2; })
                     .throttle(300);
};
 
// Apply the function to our Observable and subscribe to the new Observable
queryStream(observable).subscribe(function(data) { console.log(data); });
 
// Write some data to the Observable
for (var i = 0; i < 100; i++) {
    observable.write(i);
}