VimUnDoLgZV?KoY3Uy-Խָ#U   P bH_vP g 5_vP g 5_vP gB var start = options && options.start >= 0 ? options.start : null5_vP g1 var finish = options && options.end || Infinity5_vP g8 var encoding = options && options.encoding || 'binary'5_vP gu var buffer = Buffer(size)5_vP g)% function readCallback(e, count) {5_vP g.# function readCallback(e, count) {5_vP g0 var buffer = Buffer(size)5_vP g> % function readCallback(e, count) {" if (e) next(error(e), state)) if (count === 0) next(end(), state)6 else state = next(buffer.slice(0, count), state), if (state && state.is === accumulated)' return next(end(), state.value) start = start + count- if (start >= finish) next(end(), state)C else fsbinding.read(fd, buffer, 0, size, start, readCallback) }5_vP g> 5_;vP gA }) < fsbinding.read(fd, buffer, 0, size, start, readCallback)5_DvP gHP fsbinding.read(fd, buffer, 0, size, start, function readCallback(e, count) {5_@?8v8P gNL fsbinding.read(fd, buffer, 0, size, start, function callback(e, count) {5_B=8v8P gSvC else fsbinding.read(fd, buffer, 0, size, start, readCallback)5_=8v8P gw5_ =8v8P g  1 var size = options && options.size || 64 * 10245_ =8v8P g  B var start = options && options.start >= 0 ? options.start : null5_ =8v8P g  1 var finish = options && options.end || Infinity5_ =8v8P g  8 var encoding = options && options.encoding || 'binary'5_ =8v8P g   var buffer = Buffer(size)5_ =8v8P g  5_6=8v8P gx > return reader(fd, buffer, 0, size, start, finish, options)5_ =8v8P hy" if (e) next(error(e), state)5_=8v8P h{) if (count === 0) next(end(), state)5_,=8v8P i 5_=8v8P i console.log()5_=8v8P i| console.log(e, count)5_=8v8P j~" console.log('>>>', e, count)5_ =8v8P k     5_=8v8P k # return append(f(fd), close(fd))5_ =8v8P k $ return append(f(fd), close([fd))5_#=8v8P k % return append(f(fd), close([ fd))5_&=8v8P l? ' return append(f(fd), close([ fd ]))5_=8v8P lT  return append(f(fd), [])5_=8v8P l^   5_=8v8P lh console.log5_%=8v8P li % return append(f(fd, options), [])5_=8v8P ll  return append(f(fd, options)5_-=8v8P lx3 return expand(open(path, options), function(fd) {5_=8v8P l   5_=8v8P l  console.log()5_=8v8P l  console.log('')5_=8v8P l  console.log('>>>')5_ "v"P m : return expand(open(path, options), function onopen(fd) {5_ "v"P m return 5_"v"P m return open()5_"v"P m" return open(path, open)5_"v"P m return open(path, options)5_"v"P m console.log('>>>', fd)5_"v"P m   5_"v"P m  console.log()5_"v"P m  console.log('')5_"v"P m  console.log('>>>')5_"v"P m3 expand(open(path, options), function onopen(fd) {5_ "v"P m  return f(fd, options)5_ "v"P m  return append(f(fd, options)5_ ("v"P m ) return append(f(fd, options), close()5_ )"v"P m + return append(f(fd, options), close([])5_ /"v"P m / return append(f(fd, options), close([ fd ])5_ ."v"P n 0 return append(f(fd, options), close([ fd ]))5_ *"v"P n . return append(f(fd, options), close([ fd))5_  ("v"P o9 , return append(f(fd, options), close(fd))5_   ,"v"P o; . return append(f(fd, options), close([ fd))5_  "v"P o= console.log('>>>', fd)5_     "v"P o   5_   "v"P o  typeof 5_   "v"P o  return typeof 5_   "v"P o  return typeof()5_    "v"P o function read(path, options) {5_  "v"P o  return typeof(pathk)5_  "v"P o  return typeof(file)5_ "v"P o  return typeof(file) === ''5_ ""v"P o " return typeof(file) === 'string'5_ ."v"P o / return typeof(file) === 'string' ? withOpen()5_  D"v"P o reader D return typeof(file) === 'string' ? withOpen(file, reader, options)5_  "v"P p reader()5_    "v"P p-5_   "v"P p2function withFile()5_   #"v"P p7#function withFile(file, f, options)5_   %"v"P p8&function withFile(file, f, options) {}5_     "v"P p9 5_     "v"P p? return expand()5_     "v"P pB return expand()5_     "v"P pG! return expand(file, function())5_   $  "v"P pN& return expand(file, function onfd())5_   '  "v"P pP( return expand(file, function onfd(fd))5_  )  "v"P pP + return expand(file, function onfd(fd) {})5_  !   "v"P pQ   5_ " !   "v"P p[  return f()5_ ! # "   "v"P p`  5_ " $ #  "v"P pi reader(file, options)5_ # % $  "v"P pp withFile()5_ $ & %  "v"P p|$ return expand(path, function(fd) {5_ % ' &  "v"P p| return reader(fd, options)5_ & ( '  "v"P p} })5_ ' ) (  "v"P qD 5_ ( * )  "v"P qI typeof()5_ ) + *  "v"P qK typeof(file)5_ * , +  "v"P qL typeof(file) === ''5_ + - ,"  "v"P qP" typeof(file) === 'number'5_ , . -,  "v"P q^- typeof(file) === 'number' ? reader()5_ - / .:  "v"P qf: typeof(file) === 'number' ? reader(file, options)5_ . 0 /;  "v"P qh 5_ / 1 0  "v"P qn expand()5_ 0 2 1  "v"P qx! expand(file, function())5_ 1 6 2"  "v"P qy# expand(file, function(fd))5_ 2 7 3 6&  "v"P q& expand(file, function(fd) {})5_ 6 8 7   "v"P q w5_ 7 9 8  "v"P r5 5_ 8 : 9  "v"P rA 5_ 9 ; :   "v"P rH options.5_ : < ;$  "v"P rN% options.flags = options.flags || ''5_ ; = <  "v"P r2 return convert({}, function(self, next, state) {5_ < > =  "v"P r2 return convert(fd, function(self, next, state) {5_ = ? >  "v"P r8 return convert({ fd: fd, function(self, next, state) {5_ > @ ?"  "v"P s 5_ ? A @"v"P sfunction writter5_ @ B A"v"P sfunction writter()5_ A C B"v"P tfunction writter(file, options)5_ B D C!"v"P t"function writter(file, options) {}5_ C E D "v"P t  5_ D F Ev%P t% 5_ E G Fv%P t%0 var size = options && options.size || 64 * 10245_ F H Gv%P t %D var start = options && options.start >= 0 ? options.start : null5_ G I Hv%P t!1 var size = options && options.size || 64 * 10245_ H J Iv%P t# $3 var finish = options && options.end || Infinity5_ I K Jv%P t*1 var finish = options && options.end || Infinity5_ J O Kv%P t+ #: var encoding = options && options.encoding || 'binary'5_ K P L O v%P t7  var buffer = Buffer(size)5_ O Q P7v%P t: "8 var encoding = options && options.encoding || 'binary'5_ P R Qv%P t]7 var encoding = options && options.encoding || 'utf-8'5_ Q S R v%P ti "  !5_ R T S v%P tq "! var flags = options.flags || ''5_ S U T:v:P t!#  "5_ T V U :v:P t 5_ U W V:v:P t$ #5_ V X W:v:P t2 options.mode = options.mode || DEFAULT_FILE_MODE5_ W Z X":v:P t!## 5_ X [ Y Z":v:P t!## 5_ Z \ [":v:P t"$#5_ [ ] \:v:P t%$5_ \ ^ ]:v:P t%var channel = require()5_ ] _ ^:v:P t%var channel = require('')5_ ^ ` _":v:P t%"var channel = require('./channel')5_ _ a `#:v:P t#%& #%%5_ ` b a$ :v:P t#%& reduce()5_ a c b$:v:P u#%& reduce(result, function())5_ b d c$:v:P u#&& reduce(result, function() {})5_ c e d$:v:P u#%' reduce(result, function() {5_ d f e$':v:P uF$&( $&'5_ e g f% :v:P uJ$&( fs.write5_ f h g%:v:P u$&( fsbinding.write()5_ g i h# :v:P u"$( var result = channel()5_ h k i# :v:P u"$( var otupt = channel()5_ i l j k$# #vP u#%(+ reduce(result, function(result, chunck) {5_ k m l%# #vP u$&( fsbinding.write(fd, )5_ l n m$ # #vP u#%(+ reduce(output, function(result, chunck) {5_ m o n$ # #vP u#%(+ reduce(output, function(offset, chunck) {5_ n p o$# #vP u#%(% reduce(output, function(, chunck) {5_ o q p&# #vP u%'( })5_ p r q& # #vP u%'( }, stat)5_ q s r% # #vP u$&(! fsbinding.write(fd, chunck, )5_ r t s% # #vP u$&(- fsbinding.write(fd, chunck, chunk.length)5_ s u t%!# #vP u$&(0 fsbinding.write(fd, chunck, 9, chunk.length)5_ t v u%/# #vP u$&(0 fsbinding.write(fd, chunck, 0, chunk.length)5_ u w v%9# #vP v$&(: fsbinding.write(fd, chunck, 0, chunk.length, position)5_ v x w!!# #vP v("$ function onwrite!$) !#(5_ w y x#% %vP v."$* function onwrite()5_ x z y#% %vP v."%* function onwrite() {}5_ y { z')& &vP v7&(+- reduce(output, function(position, chunck) {5_ z | {''& &vP v<')+5_ { } |(& &vP v='(5_ | ~ }(& &vP v?')+C fsbinding.write(fd, chunck, 0, chunk.length, position, onwrite)5_ }  ~("(&v&P vW+!function writter(file, options) {5_ ~  ("(&v&P v_+ expand = accumulators.expand5_  #("(&v&P v"$+ function onwrite() {5_ ("(&v&P v+5_ )")&v&P v5_ ("(&v&P w ,+5_ )")&v&P w,function _write()5_ $)")&v&P w ,%function _write(fd, buffer, offset, )5_ ?)")&v&P w&,?function _write(fd, buffer, offset, length, position, callback)5_ A)")&v&P w' ,Bfunction _write(fd, buffer, offset, length, position, callback) {}5_ *"*&v&P w1 .  -5_ +"+&v&P w:!.5_ ,A,vP wF!0 !/5_  ?-A-vP wG!0@ fsbinding.write(fd, chunk, 0, chunk.length, position, onwrite)5_  B-A-vP wI!0C fsbinding.write(fd, chunk, 0, chunk.length, position, function())5_  D-A-vP wJ"0F fsbinding.write(fd, chunk, 0, chunk.length, position, function() {})5_ -P F,.2 var output = channel()5_ -P F,.2 var output = queue(channel()5_ P F325_ P F3var queue = require()5_ P F3var queue = require('')5_ vP F3var cache = require('./cache')5_ vP F5_ vP F325_ *'v'P F*04*,35_ +++vP F*,8options = options || {}5_ &++vP F&(9 &(85_ +,,vP G*,8*+5_ +++vP G*+5_ +++vP G*+& options.flags = options.flags || 'r'5_ *++vP G*,65_ ,,,vP G7+,F return typeof(file) === 'string' ? withOpen(file, reader, options) :5_ , ,,vP G8+,< typeof(file) === 'number' ? reader(file, options) :5_ , ,,vP G8+,( withFile(file, reader, options)5_ &,,vP G<%'4function writter(fd, options) {5_ 3,,vP GL3553545_ /,,vP Ge/16 /155_ 0,,vP Gp/16 open()5_ 0,,vP G/16 open(path, options)5_ 0,,vP G/16 reduce(open(path, options)5_ 0(,,vP G/16( reduce(open(path, options), function()5_ 0*,,vP G/26+ reduce(open(path, options), function() {}5_ 1,,vP G027 }5_ 0',,vP G/17* reduce(open(path, options), function() {5_ 0+,,vP G028 0275_ 1 ,,vP G028 reduce()5_ 1,,vP G028 reduce(output, function())5_ 1-,,vP G028- reduce(output, function(position, chunk))5_ 1.,,vP G038/ reduce(output, function(position, chunk) {}5_ 2,,vP G139 }5_ 1,,vP G13: 1395_ 2,,vP G13: fsbinding.write()5_ 5,,vP G45, reduce(output, function(position, chunk) {5_ 5,,vP G45B fsbinding.write(fd, chunk, 0, chunk.length, position, onwrite)5_ 5,,vP G45 }, start)5_ /,,vP G/18 /175_ 1 1 1vP G028/ reduce(open(path, options), function(_, fd) {5_ 0 1 1vP G/18 var file = 5_ 01 1vP G0285_ 12 2vP G0295_ 1 2 2vP G029 capture()5_ 12 2vP G029 capture(file, function())5_ 12 2vP G039 capture(file, function() {})5_ 0 0 0vP H/1: var file = open(path, options)5_ 10 0vP H/1: var file = capture(file, function() {02: capture(file, function() {5_ 00 0vP H/19' var file = capture(file, function() {5_ 030 0vP H,/196 var file = capture(open(path, options), function() {5_ 030 0vP H.02: 0295_ 1 0 0vP H202: enqueue()5_ 10 0vP H902: enqueue(channel, error())5_ 20 0vP HA24:5_ 30 0vP HC235_ 3 0 0vP HD24: reduce(, function(_, fd) {5_ 1 0 0vP I02: enqueue(channel, error(e))5_ :0 0vP I;=function write::5_ <0 0vP I;=function write()5_ <0 0vP I;function write() {}5_ <0 0vP I;==function write() {5_ <0 0vP J;==function write(path) {5_ <0 0vP J;==function write(path, options) {5_ <0 0vP J'<>> <>=5_ = 0 0vP J.<>> return open5_ =0 0vP J7<>> return withOpen()5_ =0 0vP J8<>> return withOpen(path)5_ =0 0vP J=<?> return withOpen(path, options)5_ >0 0vP J@=?? options)5_ =!0 0vP JD<>?$ return withOpen(path, function() {5_ ="0 0vP JM=?@ =??5_ >0 0vP JT=?@ return reduce()5_ >$0 0vP Jn=?@& return reduce(content, function())5_ >40 0vP Js=?@5 return reduce(content, function(position, chunk))5_ >60 0vP Jt=@@8 return reduce(content, function(position, chunk) {})5_ >,0 0vP Jx=?A6 return reduce(content, function(position, chunk) {5_ ?0 0vP J}>@A })5_ >0 0vP J>@B >@A5_ ?55CvCP J>@B fs5_ 555CvCP 57C 57B5_ ,55CvCP ,.D ,.C5_ ,66CvCP +-D$ function onwrite(error, written) {5_ - 66CvCP ,.D error5_ ,66CvCP +, function onwrite(e, written) {5_ ,55CvCP +, e5_ ,44CvCP +, }5_ ,33CvCP +,5_ 2C22CvCP 13@D fsbinding.write(fd, chunk, 0, chunk.length, position, onwrite)5_ 2E22CvCP 13@G fsbinding.write(fd, chunk, 0, chunk.length, position, function())5_ 2N22CvCP 13@O fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote))5_ 2P22CvCP 14@R fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote) {})5_ 222CvCP 24B 24A5_ 3 22CvCP 24B if ()5_ 322CvCP 24B if (e)5_ ,22CvCP f,.B5_ =33CvCP {=?D =?C5_ >33CvCP ~=?D open()5_ >33CvCP =?D open(path)5_ > 33CvCP =?D var file open(path)5_ >33CvCP =?D var file = open(path)5_ >33CvCP =?D var file = open(path);5_ >33CvCP >@E >@D5_ ? 33CvCP >@E accumulate5_ &;&vP %'0%'E!function writter(path, options) { options = options || {}B var start = options && options.start >= 0 ? options.start : null8 var encoding = options && options.encoding || 'binary'" var flags = options.flags || 'w' var output = queue(channel())7 var file = capture(open(path, options), function(e) { close(channel, error(e)) }) reduce(file, function(_, fd) {. reduce(output, function(position, chunk) {P fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote) { if (e)  }) return pause() }) }) return output}5_ &&&vP %&5_ @$$vP  /Afunction _write(fd, buffer, offset, length, position, callback) { var promise = defer()D fsbinding.write(fd, chunk, 0, chunk.length, position, function() { })}5_ @@vP @function _write(fd, buffer, offset, length, position, callback) 5_ @@vP 5_ @@vP 5_ "@@vP !"& return withOpen(path, function(fd) {5_ "@@vP !"3 return reduce(content, function(wrote, chunk) {5_ "@@vP !"D fsbinding.write(fd, chunk, 0, chunk.length, position, onwrite)5_  "@@vP !" }, 0)5_  "@@vP !" }, options)5_   !   vP  "" accumulate()5_      vP   var file = open(path)5_      vP !! accumulate(open(path))5_    #  vP !!$ accumulate(open(path), function())5_    %  vP "!' accumulate(open(path), function() {})5_    "  vP !"% accumulate(open(path), function() {5_   $  vP !"' accumulate(open(path), function(fd) {5_   *  vP !"- accumulate(open(path), function(fd, rest) {5_  +  vP  "#  ""5_  $  vP !#/ accumulate(open(path), function(fd, result) {5_ !  vP  "# if ()5_  !   vP  "# if (value)5_  !  vP  "# if (value && value.isBoxed)5_   !$  vP  "#$ if (value && value.is === error)5_    "  vP !#2 accumulate(open(path), function(value, result) {5_      vP !#2 accumulate(open(path), function(value, result) {5_    $  vP !#/ convert(open(path), function(value, result) {5_    1  vP !#4 convert(open(path), function(self, next, result) {5_   !%  vP  "#% if (value && value.is === error) 5_    #  vP !#5 convert(open(path), function(self, next, initial) {5_   !  vP  "# accumulate()5_   !  vP  "# accumulate(file, function())5_   !!  vP  ### accumulate(file, function() {})5_   !  vP  "$! accumulate(file, function() {5_   !)  vP  "$, accumulate(file, function(value, rest) {5_   !"  vP !#% !#$5_   "   vP !#% if ()5_   "   vP $!#%! if (value && value.isBoxed)5_   "$  vP (!#%$ if (value && value.is === end)5_  "*  vP ,"$& "$%5_  ! #   vP /"$& if ()5_ " !"  vP 4!#&+ if (value && value.is === end) return5_ ! # ""(  vP 6!#&0 if (value && value.isBoxed === end) return5_ " $ #""  vP :!$&( if (value && value.isBoxed) return5_ # % $#  vP ;"$' return5_ $ & %#   vP ="$' if ()5_ % ' &#  vP E"$' if (value.is === end)5_ & ( '#  vP F"$' if (value.is !== end)5_ ' ) (##  vP I"$'$ if (value.is !== end) next()5_ ( * )!#  vP N "'& accumulate(file, function(value) {5_ ) / *$  vP Q#$ if (value )5_ * 0 + /#  vP b#%' #%&5_ / 1 0$  vP l#&' } else {}5_ 0 2 1$  vP l$&) $&(5_ 1 3 2%  vP u$&) reader()5_ 2 4 3%  vP y$&) accumulate()5_ 3 5 4%%  vP $&)' accumulate(content, function())5_ 4 6 5%3  vP $&)4 accumulate(content, function(value, result))5_ 5 7 6%5  vP $')7 accumulate(content, function(value, result) {})5_ 6 8 7%2  vP $&*5 accumulate(content, function(value, result) {5_ 7 9 8 )  vP  "+  "*5_ 8 : 9)  vP (*+ })5_ 9 ; :!  vP  ! var state = initial5_ : < ;(   vP ')* }, state)5_ ; = <&   vP %'* })5_ < > =%*  vP $&*- accumulate(content, function(value) {5_ = ? > 1  vP  "*5_ > @ ?!  vP  !5_ ? A @ 2  vP !*5 convert(open(path), function(file, next, initial) {5_ @ B A /  vP !*2 convert(open(path), function(file, next, stat) {5_ A C B&  vP %'* }, initial)5_ B D C&  vP %'* }, stat)5_ C E D%2  vP $&*5 accumulate(content, function(value, result) {5_ D F E%3  vP $&*6 accumulate(content, function(value, result`) {5_ E G F%2  vP $&*5 accumulate(content, function(value, result) {5_ F H G%)  vP %'+ %'*5_ G I H&  vP %'+ if ()5_ H J I&%  vP %'+% if (value && value.isBoxed)5_ I K J&+  vP %'+, if (value && value.isBoxed) next()5_ J L K&7  vP &(, &(+5_ K M L'  vP ')- '),5_ L N M$   vP 0$&. $&-5_ M O N)  vP 6(*. return pause()5_ N P O&*  vP C%'.- accumulate(content, function(value) {5_ O Q P)  vP L(*. return pause(fd, )5_ P R Q)   vP P(*.$ return pause(fd, chunck, )5_ Q S R&+))vP U%'.. accumulate(content, function(chunck) {5_ R T S)"))vP Z(*.# return pause(fd, chunk, )5_ S U T)3))vP e(*.4 return pause(fd, chunk, 0, chunk.length, )5_ T V U'))vP l!/ !.5_ U W V **vP w!0 !/5_ V X W!!++vP  "0! var position = options.position5_ W Y X+;++vP *,0< return pause(fd, chunk, 0, chunk.length, position)5_ X Z Y+G++vP *,0H return pause(fd, chunk, 0, chunk.length, position, function())5_ Y [ Z+I++vP *-0K return pause(fd, chunk, 0, chunk.length, position, function() {})5_ Z \ [+F++vP *,1I return pause(fd, chunk, 0, chunk.length, position, function() {5_ [ ] \+M++vP +-2 +-15_ \ ^ ],++vP +-2 if ()5_ ] _ ^,++vP +-2 if (e)5_ ^ ` _,++vP +-2 if (e) next()5_ _ a `,++vP +-2 if (e) next(error())5_ ` b a,++vP ,.3 ,.25_ a c b- ++vP ,- 5_ b d c,++vP +-2! if (e) next(error(e))5_ c e d,++vP ,.3 ,.25_ d f e-A++vP -/35_ e g f($++vP ')4- accumulate(content, function(chunk) {5_ f h g.++vP -/45_ g i h. ++vP -/4 onChunk5_ h j i.'++vP -/4' accumulate(content, onChunk5_ i k j+++vP )+4 fsbinding.write();(fd, chunk, 0, chunk.length, position, function(e, wrote) {*,4Q return pause(fd, chunk, 0, chunk.length, position, function(e, wrote) {5_ j l k. *6*:vP .04 .035_ k m l*6*:vP var Box = require5 45_ l n m,6,:vP 6var Box = require()5_ m o n,6,:vP 6var Box = require('')5_ n p o,6,:vP  var pause = Box 765_ o q p.6.:vP " 8var pause = Box()5_ p r q=.6.:vP & 8?var pause = Box('Indicator that source has being accumulateed')5_ q s r&.6.:vP 9 85_ r t s /6/:vP 9 if ()5_ s u t&/6/:vP 9' if (state && state.is === paused)5_ t v u$/6/:vP : 95_ u w vvP :3 var size = options && options.size || 64 * 1024D var start = options && options.start >= 0 ? options.start : null3 var finish = options && options.end || Infinity: var encoding = options && options.encoding || 'binary' var buffer = Buffer(size)5_ v x w vP 7 65_ w y x vP ;D var start = options && options.start >= 0 ? options.start : null5_ x z y vP ;3 var finish = options && options.end || Infinity5_ y { z vP ;: var encoding = options && options.encoding || 'binary'5_ z | { vP ; var buffer = Buffer(size)5_ { } | vP ;5_ | ~ } vP  5_ } ~ vP 5_ ~  vP : return options.start = 5_ vP ( // TODO: Handle state.is === pause5_ $vP K#%9(function write(path, content, options) {5_ 'vP N&(93 convert(open(path), function(file, next, state) {5_ (vP o')9. accumulate(file, function(value, result) {5_ ' vP &(9+ convert(fd, function(file, next, state) {5_ ' vP &(90 convert(content, function(file, next, state) {5_ 'vP &(90 convert(content, function(self, next, state) {5_ 9vP x995_ , vP i,.; ,.:5_ -vP t,.; console.log()5_ -vP t,.; console.log('')5_ -vP w,.; console.log('>>>')5_ (vP '(1 accumulate(content, function(value, result) {5_ (vP '(# if (value && value.isBoxed) {5_ (vP '(1 if (value.is !== end) next(value, result)5_ (vP '( } else {5_ (vP '( var fd = value5_ (vP '(! console.log('>>>', value)5_ 2vP 12 })5_ 1vP 01 }5_ (0(vP '13 5 accumulate(content, function onChunk(chunk) {9 if (value && value.isBoxed) next(value, result)T fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote) {( if (e) return next(error(e))B position = position === null ? null : position + wrote( accumulate(content, onChunk) }) return pause() }, state)5_ )40(vP (*35 if (value && value.isBoxed) next(value, result)5_ ),0(vP (*34 if (value && value.isBoxed) next(value, state)5_ )0(vP (*34 if (value && value.isBoxed) next(chunk, state)5_ )0(vP (*34 if (value && chunk.isBoxed) next(chunk, state)5_ )"0(vP (*34 if (chunk && chunk.isBoxed) next(chunk, state)5_ )(0(vP )+4 )+35_ *1(vP )+4 console.log()5_ *1(vP )+4 console.log('')5_ *1(vP )+4 console.log('>>>')5_ &!1(vP e%'4) var position = options.position || null5_ &1(vP g%'4& var position = options.state || null5_ &1(vP k%'4& var position = options.start || null5_ +:& &vP s*,4P fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote) {5_ -6& &vP y,.4> position = position === null ? null : position + wrote5_ -& &vP },.4; position = position === null ? null : start + wrote5_ -& &vP ,.48 position = start === null ? null : start + wrote5_ *& &vP )+4 console.log('>>>', chunk)5_ '"& &vP 9')5 ')45_ (& &vP E'( content5_ +%& &vP Վ+-5 +-45_ ,& &vP Փ+-5 console.log()5_ ,& &vP Ֆ+-5 console.log(wrote)5_ , & &vP կ+-5! console.log('<<<', wrote)5_ ,!& &vP ղ+-5# console.log('<<<', slice())5_ ,& &vP +,, console.log('<<<', slice(arguments))5_ "& &vP #%function writeChunck"%5"$45_ $( (vP #%6function writeChunck()5_ $)( (vP #%6)function writeChunck(fd, chunk, position)5_ $+( (vP #&6,function writeChunck(fd, chunk, position) {}5_ $) )vP $&8 $&75_ %* *vP %'9 %'85_ &+ +vP %'9 fsbinding.write()5_ &B+ +vP %'9C fsbinding.write(fd, chunk, 0, chunk.length, position, function())5_ &D+ +vP %(9F fsbinding.write(fd, chunk, 0, chunk.length, position, function() {})5_ &, ,vP &(; &(:5_ '- -vP "&(; if ()5_ &A- -vP %%';D fsbinding.write(fd, chunk, 0, chunk.length, position, function() {5_ '- -vP )&(; if (error)5_ '- -vP 3&(; if (error) deliver()5_ '- -vP 6&(; if (error) deliver(error)5_ '- -vP 8&(; deliver(error)5_ ' - -vP =&(; deliver(error || value)5_ (- -vP C(*< (*;5_ . .vP Rvar eventual = require= <5_ 0 0vP W>var eventual = require()5_ 0 0vP W>var eventual = require('')5_  0 0vP ^>+var eventual = require('eventual/eventual')5_ ,0 0vP _>,var eventuals = require('eventual/eventual')5_ 02 2vP /1@&function write(fd, content, options) {5_ 22 2vP 24A 24@5_ 3 2 2vP 24A expand()5_ 32 2vP 24A expand(file, function())5_ 32 2vP 25A expand(file, function() {})5_ 32 2vP 24B expand(file, function() {5_ 32 2vP 35C 35B5_ 42 2vP 35C return reduce()5_ 4%2 2vP 35C& return reduce(content, function())5_ 4'2 2vP 36C) return reduce(content, function() {})5_ 4$2 2vP 35D' return reduce(content, function() {5_ 52 2vP 46D })5_ 5 2 2vP 46D }, state)5_ 3 2 2vP 35E 35D5_ 42 2vP 35E position = start5_ 52 2vP 58F 57E5_ 5,2 2vP 46G8 return reduce(content, function(position, content) {5_ 8 2 2vP 79G }, start)5_ 7%2 2vP 68G% 5_ 742 2vP 79H% 79G5_ 82 2vP +79H return writeChunck()5_ 522 2vP ^46H5 return reduce(content, function(wrote, content) {5_ 82 2vP `79H return writeChunck(fd, )5_ :2 2vP h:<I :<H5_ G2 2vP lGIJ GII5_ *"2 2vP *,K *,J5_ +3 3vP *,K console.log()5_ 63 3vP 68L 68K5_ 73 3vP 68L console.log''5_ 73 3vP 68L console.log()5_ 73 3vP 68L console.log('')5_ 43 3vP 35L expand(file, function(fd) {5_ +3 3vP $*,L console.log(value)5_ +3 3vP 5*,L console.log('<<<', value)5_ )3 3vP A)+M )+L5_ *4 4vP J)+M console.log()5_ 84 4vP [78 console.log('>>>>')5_  84 4vP }79L+ position = position === null ? null :5_  64 4vP 56 var position = start5_   74 4vP 68K( position = start === null ? null :5_   8-4 4vP 79K5 position + wrote5_   8*4 4vP 79K2 state + wrote5_   824 4vP 79K2 start + wrote5_   6)4 4vP 57K3 return reduce(content, function(wrote, chunk) {5_   834 4vP 79K3 start + offset5_  6)4 4vP 57K3 return reduce(content, function(count, chunk) {5_  824 4vP 79K2 start + count5_  9,4 4vP 8:K- return writeChunck(fd, chunk, position)5_  54 4vP 57L 57K5_   64 4vP 57L var position = 05_   7*4 4vP 68L4 return reduce(content, function(offset, chunk) {5_   7(4 4vP 79M 79L5_   ;44 4vP :<M5 return writeChunck(fd, chunk, position, offset)5_   94 4vP 89, var position = start === null ? null :5_   9%4 4vP 893 start + offset5_    74 4vP T68K3 return reduce(content, function(count, chunk) {5_   :4 4vP Y9;K }, 0)5_   4 4vP dL K5_   5 5vP iLvar eventual = require()5_   5 5vP iLvar eventual = require('')5_   '5 5vP lL'var eventual = require('eventual/core')5_   85 5vP 79L< return reduce(content, eventual(function(count, chunk) {5_   8$5 5vP 79LG return reduce(sequential(content, eventual(function(count, chunk) {5_  >5 5vP L> expand = accumulators.expand, reduce = accumulators.reduce5_  ! 7 6 6vP F68M$ return expand(file, function(fd) {5_ " !=6 6vP J<>M })5_ ! # "906 6vP f8:MH return reduce(sequential(content), eventual(function(count, chunk) {5_ " $ #<6 6vP i;=M }), 0)5_ # % $96 6vP 8:M? return reduce(sequential(content), function(count, chunk) {5_ $ & %96 6vP 8:M4 return reduce(content), function(count, chunk) {5_ % ' &96 6vP 8:M3 return reduce(content, function(count, chunk) {5_ & ( '<6 6vP ;=M }, 0)5_ ' ) (*(6 6vP L)+M+function writeChunck(fd, chunk, position) {5_ ( * )+6 6vP ]+-N +-M5_ ) + *0#7 7vP t/1N$ deliver(promise, error || value)5_ * , +97 7vP 89 var wrote = 05_ + - ,927 7vP 8:M< return reduce(content, eventual(function(count, chunk) {5_ , . -:7 7vP 9: wrote = write + count5_ - / .:I7 7vP 9;LJ return writeChunck(fd, chunk, start === null ? null : start + wrote)5_ . 0 /==JvP <>? <>L /*7 return convert(content, function(self, next, state) {1 accumulate(content, function onChunk(chunk) {; if (chunk && chunk.isBoxed) return next(chunk, state)$ console.log('>>>', chunk + '')M fsbinding.write(fd, chunk, 0, chunk.length, start, function(e, wrote) {$ if (e) return next(error(e))5 start = start === null ? null : start + wrote$ accumulate(content, onChunk) }) return pause() }, state) }) */5_ / 1 0===vP <= 5_ 0 2 1"vP +? >5_ 1 3 2"vP 0? var file = open()5_ 2 4 3"vP 3@ ?5_ 3 5 4"vP 7@ return append()5_ 4 6 5"vP 8@ return append(f())5_ 5 7 6"vP ;@ return append(f(file, open))5_ 6 8 7 "vP =@! return append(f(file, options))5_ 7 9 8("vP @@* return append(f(file, options), close())5_ 8 : 9"vP G: return expand(open(path, options), function onopen(fd) {5_ 9 ; :"vP H0 return append(f(fd, options), close([ fd ]))5_ : < ;"vP H })5_ ; = <$,"vP t#%=< typeof(file) === 'number' ? reader(file, options) :5_ < > =$2"vP v#%=> typeof(file) === 'number' ? reader([ file, options) :5_ = ? >$%$%$=v=P $&> $&=5_ > @ ?& $%$=v=P %&( withFile(file, reader, options)5_ ? A @$%$=v=P %function withFile(file, f, options) {5_ @ B A#%#=v=P ) return expand(file, function onfd(fd) {5_ A C B"%"=v=P  return f(fd, options)5_ B D C!%!=v=P  })5_ C E D % =v=P }5_ D F E%=v=P 5_ E G F%=v=P 7function reader(fd, options) {5_ F H G%=v=P 875_ G I H%=v=P 8 ret5_ H J I%=v=P  return 5_ I K J%=v=P 7: return convert({ fd: fd }, function(self, next, state) {5_ J L K%=v=P 74 return convert(file, function(self, next, state) {5_ K M L(%=v=P 76 return transform(file, function(self, next, state) {5_ L N M'%=v=P 70 return transform(file, function(next, state) {5_ M O N%=v=P 875_ N P O%=v=P 8function readChunck()5_ O Q P %=v=P 8 function readChunck(start, size)5_ P R Q"%=v=P 8#function readChunck(start, size) {}5_ Q S R % =v=P 95_ R T S!%!=v=P ;:5_ S U T"%"=v=P f5_ T V U!%!=v=P ; :5_ U W V"%"=v=P < ;5_ V X W#%#=v=P < fsbinding.reader()5_ W Y X#%#=v=P < fsbinding.read()5_ X Z Y#%#=v=P = <5_ Y [ Z$%$=v=P = var buffer = Buffer()5_ Z \ [$%$=v=P = fsbinding.read(fd, buffer)5_ [ ] \+$%$=v=P =, fsbinding.read(fd, buffer, 0, size, start)5_ \ ^ ]6$%$=v=P =8 fsbinding.read(fd, buffer, 0, size, start, function())5_ ] _ ^?$%$=v=P =? fsbinding.read(fd, buffer, 0, size, start, function onread())5_ ^ ` _@$%$=v=P =A fsbinding.read(fd, buffer, 0, size, start, function onread() {}5_ _ a `%%%=v=P > }5_ ` b a%%%=v=P >"function readChunck(start, size) {5_ a c b=%%%=v=P >@ fsbinding.read(fd, buffer, 0, size, start, function onread() {5_ b d cD%%%=v=P ? >5_ c e d &%&=v=P  ? deliver()5_ d f e>&%&=v=P ?H fsbinding.read(fd, buffer, 0, size, start, function onread(e, count) {5_ e g f&%&=v=P ? deliver(promise, error || )5_ f k g&%&=v=P )@ ?5_ g l h k'%'=v=P ^   var content = readChunck A  @5_ k m l )%)=v=P }  B var content = readChunck()5_ l n m &)%)=v=P   B- var content = readChunck(file, state, size)5_ m o n )%)=v=P   C  B5_ n p o *%*=v=P   C return transform()5_ o q p *%*=v=P   C return transform(file, chu)5_ p r q *%*=v=P   C return convert()5_ q s r *%*=v=P   C return convert(file)5_ r t s !*%*=v=P   C" return convert(file, function())5_ s u t #*%*=v=P   C% return convert(file, function() {})5_ t v u +%+=v=P   D# return convert(file, function() {5_ u w v 1+%+=v=P   D4 return convert(file, function(self, next, start) {5_ v x w 0+%+=v=P   E   D5_ w y x ,%,=v=P    E accumulate()5_ x z y ,%,=v=P   E accumulate(file, function())5_ y { z !,%,=v=P   E# accumulate(file, function() {})5_ z | { -%-=v=P   F4 return convert(file, function(self, next, state) {5_ { } | 0-%-=v=P '  F3 return expand(file, function(self, next, state) {5_ | ~ } #-%-=v=P 7  F& return expand(file, function(fd, ) {5_ }  ~ -%-=v=P 8  F! accumulate(file, function() {5_ ~  "-%-=v=P E  F% return convert(file, function() {5_   4-%-=v=P Q  F7 return convert(file, function(self, next, result) {5_  3-%-=v=P V  F6 return convert(file, function(self, next, state) {5_  4-%-=v=P X  G   F5_  .%.=v=P m  G var chunk = readChunck()5_ .%.=v=P G&function readChunck(fd, start, size) {5_ .%.=v=P  var buffer = Buffer(size)5_  -%-=v=P   F- var chunk = readChunck(fd, start, size)5_  -%-=v=P   F5 var chunk = readChunck(fd, buffer, start, size)5_  -%-=v=P   G   F5_  .%.=v=P   G when()5_  .%.=v=P   G when(read, function())5_  .%.=v=P  G when(read, function() {})5_  /%/=v=P   H when(read, function() {5_    3v3P   H4 var read = readChunck(fd, buffer, start, size)5_    3v3P    var read = 5_    3v3P   G when(read, function() {5_  9  3v3P   G< when(readChunck(fd, buffer, start, size), function() {5_  =  3v3P   G5_  5  3v3P   H8 return convert(file, function(self, next, initial) {5_    3v3P   H5_    3v3P   H state = next()5_    3v3P   H" state = next(count, state)5_  "  3v3P   H/ state = next(buffer.slice(count, state)5_  *  3v3P    H2 state = next(buffer.slice(0, count, state)5_  2  3v3P !  H5_    3v3P *  J   I5_    3v3P .   var 5_    3v3P /  I5_  vP :  I 5_  vP <  I start = start + count5_  &vP F  I5 start = start === null ? start: start + count5_  &vP Q J  I5_  vP X J if ()5_ vP k J if (state)5_ vP s J if (start > end)5_ vP v J if (start > end )5_ vP x J if (start >= end )5_ (vP | J( if (start >= end || count === 0)5_ .vP  J/ if (start >= end || count === 0) next()5_ 3vP  J4 if (start >= end || count === 0) next(end())5_ :vP  J; if (start >= end || count === 0) next(end(), start)5_ 9vP K J5_  8  vP   KA when(readChunck(fd, buffer, start, size), function(count) {5_   ? 9v9P K else 5_  ? 9v9P K else readChunck()5_ / ? 9v9P K0 else readChunck(fd, buffer, start, size)5_   ? 9v9P K0 else readChunck(fd, buffer, start, size)5_ 5 ? 9v9P K5 else when(readChunck(fd, buffer, start, size)5_  5 ? 9v9P   L   K5_   ? 9v9P   L function onError()5_   ? 9v9P   L function onError() {}5_   ? 9v9P   M function onError() {5_   ? 9v9P   M function onError(error) {5_  % ? 9v9P   M& function onError(error) { next()5_  + ? 9v9P   M- function onError(error) { next(error())5_   ? 9v9P   M. function onError(error) { next(error(e))5_  * ? 9v9P   M* function onError(e) { next(error(e))5_   ? 9v9P    }5_  ? 9v9P  L })5_  ? 9v9P M L5_ & ? 9v9P ! &(N &(M5_   ? 9v9P  O  N5_   ? 9v9P     console.log5_ " ? 9v9P  N# deliver(promise, error || size)5_ " ? 9v9P ?O N5_  ? 9v9P D O console.log()5_  ? 9v9P vO; if (start >= end || count === 0) next(end(), state)5_  ? 9v9P & console.log(count, start, end)5_ !+v+P O N5_ -+v+P P O5_ +v+P P next()5_ +v+P P next(end())5_  +v+P Q P5_    +v+P Q if ()5_ %  +v+P R Q5_ !!+v+P R return start5_ !!+v+P R5_ ""+v+P S return state5_ ""+v+P S' if (state && start.is == pause)5_ ""+v+P S return next()5_ ""+v+P S return next(start)5_ ""+v+P S return next()5_  ""+v+P S" next(end(), start.value)5_ ""+v+P ^T S5_  ##+v+P `T if ()5_ ##+v+P f return nextT if (count === 0)5_ $$+v+P jU return next()5_ $$+v+P kU return next(end())5_ 2v2P s U3 state = next(buffer.slice(0, count), state)5_ 2v2P s  5_ 2v2P uV U T5_ 22v2P wV5_    5v5P z W6 start = start === null ? start : start + count5_    5v5P {   5_   5v5P |WV5_   5v5P W4 start = start === null ? start : start + count5_ vP X W5_ vP X else ig ()5_ "vP X) return next(end(), start.value)5_ vP X else if ()5_ !vP X! else if (state >= finish)5_ #vP X$ else if (state >= finish) {}5_ vP  }5_ #vP X# else if (state >= finish) {5_  vP Y X5_ vP Y return next()5_ vP Y return next(end())5_ !vP Y5_ vP > if (start >= finish || count === 0) next(end(), state)5_  vP YH else when(readChunck(fd, buffer, start, size), onChunk, onError)5_ vP # Z  Y5_  vP %  convert5_  vP ' 5_ vP /Y! else if (state >= finish)5_ NvP dOQfunction writterNQZNPY5_ PvP rOPfunction writter()5_ PvP s OP5_ OvP tOQZOQY5_ PvP ~OQZfunction writter()5_ PvP ~ORZfunction writter() {}5_ PvP OQ[function writter() {5_ PvP PR\ PR[5_ PvP OQ\!function writter(file, content) {5_ TTZv P SU\ options = options || {}# var start = options.start || null/ return sequential(expand(file, function(fd) {< return reduce(content, eventual(function(wrote, chunk) {1 return writeChunck(fd, chunk, start, wrote) }), 0) }))}5_  Q TTv P PYU return 5_  X[[v P WX5_   ZZZv P Y[[ }5_   XZZv P !XZ[5_   Z=A"v,P Za] Z\\5_   \%=A"v,P "[]b& options.flags = options.flags || 'r'5_   ]:=A"v,P \^bF return typeof(file) === 'string' ? withOpen(file, reader, options) :5_   ^+=A"v,P ]_b@ typeof(file) === 'number' ? reader([ file ], options) :5_  ^6=A"v,P ]_bA typeof(file) === 'number' ? writter([ file ], options) :5_  ^>=A"v,P ]_bI typeof(file) === 'number' ? writter([ file ], content options) :5_ _=A"v,P ^`b" reader([ file ], options)5_ _=A"v,P #^`b reader([ file, options)5_ A=A"v,P @Bb" reader([ file ], options)5_  A=A"v,P $@Bb reader([ file, options)5_  R=A"v,P RTc RTb5_   S=A"v,P RTc var content = options.content5_   S =A"v,P %RTc var content = options.content;5_    P =A"v,P (&OQc*function writter(file, content, options) {5_   S =A"v,P +RTc var content = options.content5_   S=A"v,P .RTc var input = options.content5_   U=A"v,P 2'TVc< return reduce(content, eventual(function(wrote, chunk) {5_   ]=A"v,P ;(]_d ]_c5_   [=A"v,P DZ\d(function write(file, content, options) {5_   ^=A"v,P F)]_d options.input = content5_   `@=A"v,P N*_adJ typeof(file) === 'number' ? writter([ file ], content, options) :5_   a=A"v,P S+`bd reader(file, options)5_   b=A"v,P X,ab5_   KKK"v"P JLc- deliver(promise, error || value + offset)5_   K!KK"v"P JLc( deliver(promise, error || + offset)5_   KKK"v"P JLc& deliver(promise, error || offset)5_  K$KK"v"P JLc% deliver(promise, error || offset)5_  ! K%KK"v"P .JLc+ deliver(promise, error || offset value)5_ " !UKK"v"P $UWd UWc5_ ! # "VKK"v"P (UWd console.log()5_ " $ #VKK"v"P )UWd console.log('')5_ # % $VKK"v"P +UWd console.log('>>>')5_ $ & %V KK"v"P 5UWd& console.log('>>>', wrote, chunk)5_ % ' &V&KK"v"P 9UWd, console.log('>>>', wrote, Stringchunk)5_ & ( 'V-KK"v"P :/UWd- console.log('>>>', wrote, String(chunk)5_ ' ) (HKK"v"P 0GH" console.log(fd, chunk, position)5_ ( . )U-JJ"v"P 3TVc. console.log('>>>', wrote, String(chunk))5_ ) / * .UJJ"v"P 4TVc console.log('>>>', wrote)5_ . H /I#JJ"v"P 5HJc$ console.log('<<<', error, value)5_ / I 0 H+ , +v+P , whend c5_ H J I2v2P 2e3 state = next(buffer.slice(0, count), state)5_ I K J 2v2P 4e when()5_ J L K<2v2P @e= when(next(buffer.slice(0, count), state), function())5_ K M L>2v2P @e@ when(next(buffer.slice(0, count), state), function() {})5_ L N M 2v2P Cf })5_ M O N;2v2P Jf> when(next(buffer.slice(0, count), state), function() {5_ N P OB2v2P OfE when(next(buffer.slice(0, count), state), function(restult) {5_ O Q PCvP Wf . if (state && state.is === accumulated)) return next(end(), state.value)! else if (start >= finish)# return next(end(), state)' if (state && state.is == pause) return stateC when(readChunck(fd, buffer, start, size), onChunk, onError) }, onError)5_ P R QKvP Z] }, onError)5_ Q S RKvP \ state = 5_ R T SKvP ]] \5_ S U TKvP bg f5_ T V U   KvP hg) return next(end(), state.value)5_ U W V  KvP ig! else if (start >= finish)5_ V X W   KvP jg# return next(end(), state)5_ W Y X  KvP k5_ X Z YKvP mf' if (state && state.is == pause)5_ Y [ Z KvP of return state5_ Z \ [ KvP pf5_ [ ] \  KvP rgC when(readChunck(fd, buffer, start, size), onChunk, onError)5_ \ ^ ]  KvP s5_ ] _ ^ KvP }  g   f5_ ^ ` _   KvP   g function onNext()5_ _ a `   KvP   g function onNext(value)5_ ` b a   KvP  g function onNext(value) {}5_ a c b !!KvP  i  h5_ b d c ""KvP  j  i5_ c e d ##KvP  j if ()5_ d f e   EvP j 0 if (state && state.is === accumulated)+ return next(end(), state.value)# else if (start >= finish)% return next(end(), state)) if (state && state.is == pause) return stateE when(readChunck(fd, buffer, start, size), onChunk, onError) }, onError)5_ e g f  OvP    start = result5_ f h g  OvP    if (sta)5_ g i h  OvP  `  _5_ h j i   OvP  j  i5_ i k j**-v-P j+ return next(end(), state.value)# else if (start >= finish)% return next(end(), state)) if (state && state.is == pause) return stateE when(readChunck(fd, buffer, start, size), onChunk, onError)5_ j l k*-v-P 5_ k m l*-v-P i5_ l n m +*-v-P   k   j5_ m o n *-v-P   k function onChunk()5_ n p o *-v-P  k function onChunk() {}5_ o q p *-v-P   l function onChunk() {5_ p r q vP l if (count === 0)# return next(end(), state)6 start = start === null ? start : start + countD when(next(buffer.slice(0, count), state), function(result) {5_ q s r vP  h  g5_ r t s!!!-v-P  "mI when(readChunck(fd, buffer, start, size), function onChunk(count) {5_ s u t!!-v-P m5_ t v u!!-v-P 5_ u w v  -v-P l5_ v x w !!-v-P  5_ w y x   -v-P  ! , function onChunk(count) {5_ x z y   -v-P  L when(next(buffer.slice(0, count), state), function(result) {5_ y { z   -v-P   state = result5_ z | {   -v-P   }, onError)5_ { } |   -v-P  5_ | ~ }   -v-P   }, onError)5_ }  ~  -v-P  " onNext"g !f5_ ~ ! ""-v-P 8 "h onNext()5_  !""-v-P ' "h onNext(initial)5_ !""-v-P ): "h onNext(start)5_ ""-v-P i h5_ ##-v-P i console.log()5_ ##-v-P ;i console.log('')5_ ##-v-P <i console.log('>>')5_  / v P @iB when(readChunck(fd, buffer, start, size), onNext, onError)5_ / v P AiJ when(state = next(buffer.slice(0, count), state), onNext, onError)5_ / v P B console.log('>>', value)5_ $$7v P C#%T}#%h /*- var content = readChunck(file, start, size)4 return transform(file, function(next, fd, state) {J fsbinding.read(fd, buffer, 0, size, start, function onread(e, count) {) if (e) return next(error(e), state)0 if (count === 0) return next(end(), state)6 else state = next(buffer.slice(0, count), state), if (state && state.is === accumulated)' return next(end(), state.value)& if (state && state.is === pause) return state start = start + count- if (start >= finish) next(end(), state)= else fsbinding.read(fd, buffer, 0, size, start, onread) }) }) */}5_ :$$v P D9:, console.log('<<<', error, value, offset)5_ E$$v P EDE console.log('>>>', wrote)5_ ($$v P (*S (*R5_ )"$$v P 6(+S' // TODO: Close won't execute if take 5_ * $$v P <)+T // take 5_ )5$$v P >(*T5 // TODO: Close won't execute if part of the content5_ *$$v P AF)+T // 5_ $$v P PU T5_ %%v P SG convert5_ $$v P \U T5_ %%v P `U console.log()5_ %%v P aHU console.log('')5_  $$-v-P   i  j console.log()5_  $$-v-P = j console.log(count)5_  - -5v5P > j" console.log('>>>>', count)5_  , ,5v5P Tjreturn next(end(), state) j2 if (count === 0) return next(end(), state)5_ - -5v5P U?i j8 else state = next(buffer.slice(0, count), state)5_  vP h function rest(value) {5_ / 1 H 0 + , +v+P q  c   d function onChunk()5_ 0 2 1  , +v+P x  d function onChunk() {}5_ 1 3 2  , +v+P y  d function onChunk() { }5_ 2 4 3  , +v+P z e }5_ 3 5 4  , +v+P { e  f next next()5_ 4 6 5  , +v+P g next(readChunck())5_ 5 7 6 , +v+P g) next(readChunck(fd, buffer, start))5_ 6 8 7( , +v+P g. next(readChunck(fd, buffer, start, size)5_ 7 9 8. , +v+P g6 next(readChunck(fd, buffer, start, size), start)5_ 8 : 95 , +v+P 6g6 next(readChunck(fd, buffer, start, size), state)5_ 9 ; : , +v+P gD var promise = next(readChunck(fd, buffer, start, size), state)5_ : < ; , +v+P g h when()5_ ; = <  , +v+P h when(promise, function())5_ < > = , +v+P h" when(promise, function() {})5_ = ? >  , +v+P h when(promise, function() { })5_ > @ ? , +v+P i }, onError)5_ ? A @ , +v+P i+ when(promise, function onComplete() {5_ @ B A  , +v+P   i function onComplete() {5_ A C B  , +v+P   i$ function onComplete(restult) {5_ B D C ! , +v+P   i# function onComplete(result) {5_ C E D  , +v+P   i  j stat = result5_ D F E  , +v+P  j5_ E G F  , +v+P  k state = result5_ F G , +v+P 7 k 5_ ) + . *TJJ"v"P ,SUcE return reduce(sequential(input, eventual(function(wrote, chunk) {5_ * , +T"JJ"v"P .SUcF return reduce(sequential(input), eventual(function(wrote, chunk) {5_ + - ,T.JJ"v"P 0SUc= return reduce(sequential(input), function(wrote, chunk) {5_ , -WJJ"v"P 32VXc }, 0)5_   P&=A"v,P &OQc+function writter(file, content, optionbs) {5_ vP YJ return when(readChunck(fd, buffer, start, size), onChunk, onError)5_ vP WX if ()5_  vP \  J; var offset = start === null ? start : start + count5_  /%/=v=P   H when(read, functio() {5_ g i k h<@vP - @  A5_ h j i BFvP :  B  Cexpand(file, function(fd) {< return reduce(content, eventual(function(wrote, chunk) {1 return writeChunck(fd, chunk, start, wrote) }), 0) }))5_ i j BFvP =  H expand(file, function(fd) {5_   54 4vP P46K- return expand(file, eventualsfunction(fd) {5_   -4 4vP ,.K- deliver(promise, error || offset + value)5_ ((4 4vP ')K3function writeChunck(fd, chunk, position, offset) {5_ 824 4vP 89K5_ 8,4 4vP 79L offset69L3 var position = start === null ? null : offset5_ 7 4 4vP 68M9 var writes = reduce(content, function(wrote, chunk) {5_ 74 4vP 68M6 var writes = map(content, function(wrote, chunk) {5_ <4 4vP ;=M })5_ 84 4vP 795_ ;4 4vP =;<L ;=M return reduce()5_ <4 4vP @;=M% return reduce(writes, function())5_ <#4 4vP N;=M1 return reduce(writes, function(count, wrote))5_ <04 4vP U;=M4 return reduce(writes, function(count, wrote) {})5_ <24 4vP W;=MJ return reduce(writes, function(count, wrote) { return count + wrote })5_ <I4 4vP \;=MM return reduce(writes, function(count, wrote) { return count + wrote }, 0)5_ 45 5vP dM5 accumulated = core.accumulated, drop = core.drop, map = core.map5_ 8.5 5vP 79N/ var writes = map(content, function(chunk) {5_ :%5 5vP 9;Nposition + wrote8;N< position = position === null ? null : position + wrote5_ 9%4 4vP +8:Lposition + wrote7:L< position = position === null ? null : position + wrote5_ *& &vP )+5_ 'vP q&(5_ 6'5vP t575_ ''5vP ~&67/ accumulate(content, function(value, result) {! if (value && value.isBoxed) {/ if (value.is !== end) next(value, result) } else { var fd = value3 accumulate(content, function onChunk(chunk) {7 if (value && value.isBoxed) next(value, result)R fsbinding.write(fd, chunk, 0, chunk.length, position, function(e, wrote) {& if (e) return next(error(e))@ position = position === null ? null : position + wrote& accumulate(content, onChunk) }) return pause() }, state) }5_ ' '5vP &(7, convert(content, function(value, result) {5_ ~ vP : 5_  vP 5_ vP 9 : var buffer = Buffer(size)5_ * , / +"#  vP V!#&! if (value && value.isBoxed)5_ + - ,"   vP W"#&5_ , . -#  vP X"$5_ - .#  vP X#$& #%'5_ $$$vP #%/5_ i k j$# #vP u#%( , function(result, chunck) {5_ X Z Y:v:P t#*function writter(file, content, options) {5_ K M O Lv%P t, 5_ L N Mv%P t. " var buffer = Buffer(size)5_ M Nv%P t/ 5_ 2 4 6 3$  "v"P qz6 expand(file, function(fd) { return reader()})5_ 3 5 43  "v"P q~A expand(file, function(fd) { return reader(fd, options)})5_ 4 5?  "v"P qB expand(file, function(fd) { return reader(fd, options) })5_     "v"P p  expand()5_   "v"P p! expand(file)5_  "v"P p% expand(file, reader)5_    "v"P p5_   "v"P p 5_  "v"P p 5_   "v"P oD(function withOpen(path, task, options) {5_"v"P m 5_"v"P l' return expand(, function onopen(fd) {5_"v"P l  var file = open(path, options)5_ "v"P l! var file = open(path, options);5_ =8v8P l(: return append(expand(open(path, options), function(fd) {5_=8v8P l-  return f(fd), close([ fd ]))5_ =8v8P l/  return f(fd)5_ =8v8P i  return e ? 5_=8v8P inext(error(e), state)& return e ? next(error(e), state)5_&=8v8P i( return e ? next(error(e), state) :5_ =8v8P i 3 count === 0) return next(end(), state)5_=8v8P i4 count === 0 ? return next(end(), state)5_"=8v8P i- count === 0 ? next(end(), state)5_-=8v8P i. count === 0 ? next(end(), state) 5