VimUnDoM=6~i5;q!((eX#eu@ttttPE_PӨ5_PӨ""5_ PӬ "use strict"5_ Pӭ5_PӰ function5_Pӱfunction5_Pӳfunction pipe()5_ Pӹfunction pipe(input, output)5_ Pӹfunction pipe(input, output) {}5_ PӺ* Takes input sequence and pipes all of it 5_ -P- Takes input sequence and pipes all of it's 5_ +P2 Takes input sequence and pipes it to the output 5_  3P3 Takes input sequence and pipes it to the `output 5_ FPN Takes input sequence and pipes it to the `output` (which should be a channel5_GPG Takes input sequence and pipes it to the `output` (which is a channel5_P or something 5_%P  5_P 5_ vP׾function pipe(input, output) { /**O Takes input sequence and pipes it to the `output` (which is a channel, signal& or something that implements `emit`. **/ }5_vP O Takes input sequence and pipes it to the `output` (which is a channel, signal5_vP P Takes `input sequence and pipes it to the `output` (which is a channel, signal5_KvP Q Takes `input` sequence and pipes it to the `output` (which is a channel, signal5_vP  signal5_vP  signalKor something that implements `emit`. Note that end piped `input` will close M or something that implements `emit`. Note that end piped `input` will close5_vP T signal or something that implements `emit`. Note that end piped `input` will close5_+vP S signal or anything that implements `emit`. Note that end piped `input` will close5_AvP T signal or anything that implements `emit`). Note that end piped `input` will close5_vP " from the piped`input` will close5_vP $ from the piped`input`-s will close5_%vP 4 fail. If you need to pipe multiple inputs do `pipe % from the piped `input`-s will close5_  vPB 5_! vPP 5_ "! vPQ  5_!#" vPr  5_"$# vPu  accumulate()5_#%$ vPy  accumulate(input, function())5_$&% vPz " accumulate(input, function() {})5_%'& vP|  accumulate(input, function() {5_&(' "vP} % accumulate(input, function(value) {5_')( )vP؁   5_(*) vP؇  emit()5_)+*vP؋var emit = require5_*,+vP؏var emit = require()5_+-,vP؏var emit = require("")5_,.-vPؔ5_-/.vPؖvar emit = require("./emit")5_.0/!vPؙ5_/10!vP؜"var emit = require("./accumulate")5_021!vP؞"var emit = require("./accumulate")5_132!vP 5_243 !vP try {}5_354!vP emit(output, value)5_465!vP 5_576 !vP } catch ()5_687!vP } catch (error)5_798!vP } catch (error) {}5_8:9!vP } catch (error) {5_9;:!vP }5_:<;!vP try {5_;=<!vP emit(output, value)5_<>=!vP5_=?> )!vP  you  ) that way output will close on last end.5_>@? 1!vP& it 1 you'll be piping then you can create a channel 5_?A@!vP^ it's items into output. 5_@BA!vPx 5_ACB 0!vPه N you'll be piping then you can create a channel and pipe flattened version of5_BDC"!vPً // closed. Although it" // TODO: At the moment signal 5_CED*!vPٹ* // closed. Although it's probably not 5_DFEA!vPٿ // thatA // closed. Although it's probably not a very good default as 5_EGF!vP  // that's why it's closed. 5_FHG!vP  // that's why it's closed.5_GIH!vP"H // TODO: At the moment signal errors if values are emitted when it's5_HJI!vP"I // closed. Although it's probably not a very good default as there is5_IKJ!vP"H // no way of knowing if consumer of channel completed reductions and5_JLK!vP#F // that's why it's closed. Maybe instead signal should just return5_KML!vP#? // `accumulated` to cause closing of things piping into it.5_LNM!vP%5_MON!vP&5_NPO!vP'5_OQP!vP( 5_PRQ!vP- emit(output, value)5_QSR!vP4$ var result = emit(output, value)5_RTS !vP7 if  result = emit(output, value)5_SUT!vP; if ()5_TVU !vP=  result = emit(output, value)5_UWV !vPA 5_VXW!vPE *var accumulated = require("./accumulated")5_WYX !vPH // If res5_XZY%!vPU% // If signal / channel is closed 5_Y[Z!vP // 5_Z\[!vP console.log()5_[]\!vP console.log(value)5_\^]!vP // 5_]_^!vP if ()5_^`_!vP if (result)5__a`!vP5_`ba!vPvar end = require()5_acb!vPvar end = require("")5_bdc"!vP" if (value && value.is === end)5_ced#!vP#* if (value && value.is === end) close()5_dfe!vP& close()5_egf!vP, return close()5_fhg!vP2" if (value && value.is === end)5_gih!vP4) return if (value && value.is === end)5_hji%!vP5% return value && value.is === end)5_ikj !vP7& return value && value.is === end ?close(value.value) return close(value.value)5_jlk-!vP;9 return value && value.is === end ? close(value.value)5_kmlA!vP>A return value && value.is === end ? close(output, value.value)5_lnm !vPA return emit(output, value)5_mon!vPG5_npo!vPJvar close = require()5_osp!vPJvar close = require("")5_ptqs!vP@ 5_st!vPD return o5_prsq!vP:6 returned accumulate(input, function(value, result) {5_qr !vP<4 return accumulate(input, function(value, result) {5