????JFIF??x?x????'
Server IP : 79.136.114.73 / Your IP : 18.221.40.13 Web Server : Apache/2.4.7 (Ubuntu) PHP/5.5.9-1ubuntu4.29 OpenSSL/1.0.1f System : Linux b8009 3.13.0-170-generic #220-Ubuntu SMP Thu May 9 12:40:49 UTC 2019 x86_64 User : www-data ( 33) PHP Version : 5.5.9-1ubuntu4.29 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/share/doc/node-fstream/examples/ |
Upload File : |
var fstream = require("../fstream.js") var path = require("path") var r = fstream.Reader({ path: path.dirname(__dirname) , filter: function () { return !this.basename.match(/^\./) && !this.basename.match(/^node_modules$/) !this.basename.match(/^deep-copy$/) } }) var w = fstream.Writer({ path: path.resolve(__dirname, "deep-copy") , type: "Directory" }) var indent = "" var escape = {} r.on("entry", appears) r.on("ready", function () { console.error("ready to begin!", r.path) }) function appears (entry) { console.error(indent + "a %s appears!", entry.type, entry.basename, typeof entry.basename, entry) if (foggy) { console.error("FOGGY!") var p = entry do { console.error(p.depth, p.path, p._paused) } while (p = p.parent) throw new Error("\033[mshould not have entries while foggy") } indent += "\t" entry.on("data", missile(entry)) entry.on("end", runaway(entry)) entry.on("entry", appears) } var foggy function missile (entry) { if (entry.type === "Directory") { var ended = false entry.once("end", function () { ended = true }) return function (c) { // throw in some pathological pause()/resume() behavior // just for extra fun. process.nextTick(function () { if (!foggy && !ended) { // && Math.random() < 0.3) { console.error(indent +"%s casts a spell", entry.basename) console.error("\na slowing fog comes over the battlefield...\n\033[32m") entry.pause() entry.once("resume", liftFog) foggy = setTimeout(liftFog, 10) function liftFog (who) { if (!foggy) return if (who) { console.error("%s breaks the spell!", who && who.path) } else { console.error("the spell expires!") } console.error("\033[mthe fog lifts!\n") clearTimeout(foggy) foggy = null if (entry._paused) entry.resume() } } }) } } return function (c) { var e = Math.random() < 0.5 console.error(indent + "%s %s for %d damage!", entry.basename, e ? "is struck" : "fires a chunk", c.length) } } function runaway (entry) { return function () { var e = Math.random() < 0.5 console.error(indent + "%s %s", entry.basename, e ? "turns to flee" : "is vanquished!") indent = indent.slice(0, -1) }} w.on("entry", attacks) //w.on("ready", function () { attacks(w) }) function attacks (entry) { console.error(indent + "%s %s!", entry.basename, entry.type === "Directory" ? "calls for backup" : "attacks") entry.on("entry", attacks) } ended = false r.on("end", function () { if (foggy) clearTimeout(foggy) console.error("\033[mIT'S OVER!!") console.error("A WINNAR IS YOU!") console.log("ok 1 A WINNAR IS YOU") ended = true }) process.on("exit", function () { console.log((ended ? "" : "not ") + "ok 2 ended") }) r.pipe(w)