"use strict"; const Promise = require("bluebird"); const fromLazyValue = require("./"); const pipe = require("@promistream/pipe"); const collect = require("@promistream/collect"); return Promise.try(() => { console.log("Creating stream"); let lazyValueSource = fromLazyValue(() => { console.log("Creating lazy value"); return 42; }); console.log("Piping"); return pipe([ lazyValueSource, collect() ]).read(); }).then((result) => { console.log(result); /* Creating stream Piping Creating lazy value [ 42 ] */ });