VimUnDonQRn[ġhl=cVvׂ[%var reduce = require("reduce/reduce")XXXXP$_Pvar emit = require("./emit")5_Pvar end = require("./end")5_P(var accumulate = require("./accumulate")5_+P-var accumulate = require("reduce/accumulate")5_P)var accumulate = require("reduce/reduce")5_ P- accumulate(input, function(value, result) {5_P) reduce(input, function(value, result) {5_ #P4 reduce(input, function reducePipe(value, result) {5_ +P: emit(output, value)5_ P$var emit = require("./send")5_ PB // If signal / channel is closed `accumulated` box is returned5_ P> // that will notify input that consumer is done consuming.5_  PC return value && value.is === end ? close(output, value.value) :5_ 'P: send(output, value)5_4P 7 reduce(input, function pipeReducible(value, result) {5_P/ reduce(input, function pipeReducible(value) {send(output, value) send(output, value)5_P C reduce(input, function pipeReducible(value) { send(output, value)}) })5_ P J Takes `input` sequence and pipes it to the `output` (which is a channel,5_ "P T Takes reducible `input` sequence and pipes it to the `output` (which is a channel,5_ JP K Takes reducible `input` and pipes it to the `output` (which is a channel,5_ P M signal or anything that implements `emit`). Note that first end of sequence5_ JP J Takes reducible `input` and pipes it to the `output` (which is anything,5_ P M `send` or anything that implements `emit`). Note that first end of sequence5_ P  : that implements `emit`). Note that first end of sequence5_ :P : that implements `send`). Note that first end of sequence5_ 2P 2 that implements `send`). Note that first end of 5_ +P / that implements `send`). Note that first end 5_ 0P 0 that implements `send`). Note that first `end 5_  KP K that implements `send`). Note that first `end` / `error` from any `input`5_! P  pi5_ "! P ; that implements `send`). Note that first `end` / `error` Ifrom the piped `input`-s will end an `output` causing subsequent emits to K from the piped `input`-s will end an `output` causing subsequent emits to5_!#" KP   that implements `send`). Note that first `end` / `error` from the piped `input`-s will end an `output` causing subsequent emits to5_"$# 2P J that implements `send`). Note that first `end` / `error` from the piped5_#%$ 9P, < `input`-s will end an `output` causing subsequent emits to5_$&% P2 > `input`-s will end an `output` causing subsequent `send`s toNfail. If you need to pipe multiple inputs do `pipe(flatten(multiple), output)` P fail. If you need to pipe multiple inputs do `pipe(flatten(multiple), output)`5_%'& CP7  `input`-s will end an `output` causing subsequent `send`s to fail. If you need to pipe multiple inputs do `pipe(flatten(multiple), output)`5_&(' <P9   `input`-s will end an `output` causing subsequent `send`s . If you need to pipe multiple inputs do `pipe(flatten(multiple), output)`5_')( CPV d stopping other `input`-s. If you need to pipe multiple inputs do `pipe(flatten(multiple), output)`5_(*) +P[ B stopping other `input`-s. If you need to pipe multiple inputs do5_)+* 0P\ C stopping other `input`-s. If you need to `pipe multiple inputs do5_*,+Pd # `pipe(flatten(multiple), output)`5_+-, 1Pt D stopping other `input`-s. If you need to `pipe` multiple inputs do5_,.- KP| T stopping other `input`-s. If you need to `pipe` all values form multiple inputs do5_-/.P~  inputs do`pipe(merge(multiple), output)`! `pipe(merge(multiple), output)`5_.0/ P + inputs do `pipe(merge(multiple), output)`5_/10P ) inputs do `pipe(merge(inputs), output)`Kthat way output will close on last end. If you can't flatten all the inputsM that way output will close on last end. If you can't flatten all the inputs5_0214P v inputs do `pipe(merge(inputs), output)`, that way output will close on last end. If you can't flatten all the inputs5_132;P w inputs do `pipe(merge(inputs), output)`, that way `output will close on last end. If you can't flatten all the inputs5_243KP x inputs do `pipe(merge(inputs), output)`, that way `output` will close on last end. If you can't flatten all the inputs5_354JP J inputs do `pipe(merge(inputs), output)`, that way `output` will close on5_465P/ last end. If you can't flatten all the inputs5_576 P4 once last end. If you can't flatten all the inputs5_687+P: once all inputs end. If you can't flatten all the inputs5_798P8 once all inputs end. If you can't merge all the inputsKyou'll be piping then you can create a signal and pipe flattened version ofM you'll be piping then you can create a signal and pipe flattened version of5_8:99P once all inputs end. If you can't merge all the inputs you'll be piping then you can create a signal and pipe flattened version of5_9;:LP once all inputs end. If you can't merge all the inputs up front you'll be piping then you can create a signal and pipe flattened version of5_:<;KPK once all inputs end. If you can't merge all the inputs up front you'll be5_;=<PC piping then you can create a signal and pipe flattened version of5_<>= P/ create a signal and pipe flattened version of5_=@>P0 create an signal and pipe flattened version of5_>A?@ P/ create an event and pipe flattened version of5_@BAJPP once all inputs end. If you can't merge all the inputs up front you can always5_ACBP always5_BDCP always pipe)merge event and pipe flattened version of+ merge event and pipe flattened version of5_CEDP7 always pipe merge event and pipe flattened version of5_DFE.P8 always pipe merged event and pipe flattened version of5_EGF.P. always pipe merged event and send version of5_FHG4P4 always pipe merged event and send reducibles to it5_GIHP5 always pipe merged event and send reducibles to it.GThat way emitting new input on that channel will automatically pipe allM it. That way emitting new input on that channel will automatically pipe all5_HJIGP } always pipe merged event and send reducibles to it. That way emitting new input on that channel will automatically pipe all5_IKJKP | always pipe merged event and send reducibles to it. That way sending new input on that channel will automatically pipe all5_JLKP'3 input on that channel will automatically pipe all5_KMLP+$ inputs will automatically pipe allit's items into output. it's items into output.5_LNM4P@J always pipe merged event and send reducibles to it. That way sending new5_MONPE1 always pipe merged event . That way sending new5_NPOPG0 always pipe merged event. That way sending new:inputs will automatically pipe all it's items into output.< inputs will automatically pipe all it's items into output.5_OQPKPQk always pipe merged event. That way sending new inputs will automatically pipe all it's items into output.5_PRQ<PfJ always pipe merged event. That way sending new inputs will automatically5_QSRFPiS always pipe merged event. That way sending new inputs to that event automatically5_RUSPl automatically pipe all it's items into output." pipe all it's items into output.5_SVTU/Py0 automatically pipe all it's items into output.5_UWVPvar close = require("./close")5_VXWP"var end = require("reducible/end")5_WXP#%var reduce = require("reduce/reduce")5_SUTPu. automatically pipe all it items into output.5_>@?P/ create an event and send flattened version of5_ JP I Takes reducible `input` and pipes it to the `output` (which is anything5_ P [ values can be `send` or anything that implements `emit`). Note that first end of sequence5