VimUnDo @DvjZuDLC&3K kI P G _ v PT
! function take(source, n) { /** H Returns sequence of first `n` items of the given `source`. If `source` J contains less items than `n` then that's how much items return sequence will contain. ## Example : print(take([ 1, 2, 3, 4, 5 ], 2)) // => < print(take([ 1, 2, 3 ], 5)) // => **/ / return transformer(source, function(source) { % var count = n >= 0 ? n : Infinity < return transform(source, function(next, value, result) { count = count - 1 E return count === 0 ? next(accumulated(), next(value, result)) : . count > 0 ? next(value, result) : 4 next(accumulated(), result) }) }) }5_
v P_
sequential5_ v Pa module.exports = take5_ v Pe *var accumulated = require("./accumulated")5_
v Pg *var transformer = require("./transformer")5_
v Pi &var transform = require("./transform")5_ $ v Po &var reducible = require("./transform")5_ # v Pr 5_
v Pv var reduce = require()5_
v Pv var reduce = require("")5_
v P 5_
v P var eventual = require()5_
v P var eventual = require("")5_
v P
var eventual = require("./")5_ v P 5_ v P 5_
v P
5_
v P
*
5_
v P
0 Takes `source` sequence and decorates it such 5_ /
v P
8 Takes `source` sequence and returns decorates it such 5_ .
v P
7 Takes `source` sequence and returns decorate it such 5_ 8
v P 8 Takes `source` sequence and returns decorated it such 5_
.
v P . into reduction such that any transformation 5_
F
v P P into reduction such that any transformation on the result will have guaranteed5_
v P
guaranteed5_
v P
guaranteed sequential order5_
v P
guaranteed sequential order.5_
v P* like flatten and expand 5_
v P+ like `flatten and expand 5_
v P, like `flatten` and expand 5_
v P- like `flatten` and `expand 5_ ! 6
v P< 6 like `flatten` and `expand` where items of resulting5_ " ! $
v P@ 7 like `flatten` and `expand` where items of resulting 5_ ! # " 7
v PH J like `flatten` and `expand` where returned sequences items of resulting 5_ " $ # O
v PJ O like `flatten` and `expand` where returned sequences have items of resulting 5_ # % $ '
v PW
I guaranteed sequential order. This is decorator is useful with functions5_ $ & % <
v Pc I like `flatten` and `expand` where returned sequences have items ordered5_ % ' & 9
v Pi 9 like `flatten` and `expand` when order of items ordered5_ & ( ' ?
v Po ? like `flatten` and `expand` when order of items in resulting 5_ ' ) (
v Ps by 5_ ( * )
v P~ is desired to be indexe based 5_ ) + *
v P is desired to be index based 5_ * , + 6
v P 6 is desired to be index based rather then time based.5_ + - ,
v P ' will buffer items that appear earlier5_ , . - .
v P . will buffer items that are delivered earlier5_ - / . F
v P F will buffer items that are delivered earlier then their order so use5_ . 0 /
v P that in mind it with extra care. it with extra care.5_ / 1 0 PJ
'use strict';5_ 0 2 1 PJ
"use strict';5_ 1 3 2 PJ M/*jshint asi: true undef: true es5: true node: true browser: true devel: true5_ 2 4 3 PJ 9 forin: true latedef: false globalstrict: true */5_ 3 5 4 PJ
5_ 4 6 5 ' P8 7 return reducible(source, function(_, next, initial) {5_ 5 7 6 P8 4 return reducible(source, function(next, initial) {5_ 6 9 7 P8 , return reducible(function(next, initial) {5_ 7 : 8 9 P?w , return reducible(function(next, initial) {5_ 9 ; : + P?
< return reduce(source, eventual(function(result, value) {5_ : < ; # P? I return reduce(source, eventual(function reduceSource(result, value) {5_ ; = < ( P? N return reduce(source, eventual(next)function reduceSource(result, value) {5_ < > = 2 P? X return reduce(source, eventual(next), initial)function reduceSource(result, value) {5_ = ? > P? * function reduceSource(result, value) {5_ > @ ? P? return next(result, value)5_ ? L @ P? }), initial)5_ @ M E L ' P 2 return reduce(source, eventual(next), initial)5_ L N M - P 8 return reduce(source, eventual(function()), initial)5_ M O N / P ; return reduce(source, eventual(function() {}), initial)5_ N P O , P / return reduce(source, eventual(function() {5_ O Q P 1 P < return reduce(source, eventual(function(value, result) {5_ P R Q : P = return reduce(source, eventual(function(result, result) {5_ Q S R 8 P 5_ R T S P return next()5_ S U T P 5_ T V U P console.log()5_ U W V P console.log("")5_ V X W P console.log(">>>>")5_ W Y X P ( console.log(">>>>", value, result)5_ X [ Y P ( console.log(">>>>", value, result)5_ Y \ Z [ P < return reduce(source, eventual(function(result, value) {5_ [ ] \ @ P @ return reduce(accumulate, eventual(function(result, value) {5_ \ ^ ] P * console.log("\n>>>>", value, result)5_ ] _ ^ P return next(value, result)5_ ^ ` _ P }), initial)5_ _ a `
P var reduce = require("./reduce")5_ ` b a " P $var accumulate = require("./reduce")5_ a c b P 5_ b d c P 5_ c e d P 6 return reduce(accumulate, eventual(next), initial)5_ d f e P / return accumulate, eventual(next), initial)5_ e g f , P 6 return accumulate(source, eventual(next), initial)5_ f h g ( P 2 return accumulate(source, function(), initial)5_ g i h * P 5 return accumulate(source, function() {}, initial)5_ h j i P * return accumulate(source, function() {5_ i k j P }, initial)5_ j l k 0 P 3 return accumulate(source, eventual(function() {5_ k m l < P 5_ l o m P var state = next()5_ m p n o P 5_ o q p P console.log()5_ p r q P ' console.log(value, result, state)5_ q s r P 5_ r t s ( v PT 5_ s u t ( v PV 5_ t v u ( v PW (var accumulate = require("./accumulate")5_ u w v " ( v P[ $var reduce = require("./accumulate")5_ v x w ( v Ph @ return accumulate(source, eventual(function(value, result) {5_ w y x ( v Pj ! ? return reducible(source, eventual(function(value, result) {5_ x z y ( v Pm " % var state = next(value, result)5_ y { z ( v P 5_ z | { ( v P c5_ { } | ( v P 5_ | ~ } ( v P # con5_ } ~ ( v P % - var state = next(result, value, result)5_ ~ / ( v P & 0 console.log(">>>>>", value, result, state)5_ ( v P ' return state5_ ) ( v P , ) console.log(">>>>>", value, result)5_ ( v PZ ) console.log(">>>>>", value, result)5_ ( v P[ / //var state = next(result, value, result)5_ ( v P] - var state = next(result, value, result)5_ ( v P` - return result5_ ( v P§ 5_ ( v P¬ . console.log()5_ ( v P± / console.log(value, result)5_ ( v P 0 * console.log(">>>>>>", value, result)5_ * ( v P1 5_ ( v P4 console.log()5_ ( v P5 console.log("")5_ ( v P7 1 console.log(">>>>>>")5_ ( v P 2 < return reduce(source, eventual(function(value, result) {5_ ( v P
3 ( return next(result, value, result)5_ ' ( v P= @ return accumulate(source, eventual(function(value, result) {5_ ( v PA 4 }), initial)5_ ( v PH 5 * console.log(">>>>>>", value, result)5_ ( v Pƾ 7 return accumulate(source, function(value, result) {5_ ( v P 6 }, initial)5_ ( v P 7 @ return accumulate(source, eventual(function(value, result) {5_ ( v P 8 return next(value, result)5_ # ( v P < return reduce(source, eventual(function(value, result) {5_ ( v P 9 }), initial)5_ ' ( v P : ( return next(result, value, result)5_ ( v P$ 5_ ( v P) ; console.log()5_ ( v P4 < console.log(value)5_ # ( v PC = $ console.log("########", value)5_ ( v Pg 3 return reduce(source, function(value, result) {5_ ( v Pl > }, initial)5_ $ ( v Pǁ ? % console.log("########", result)5_ # ( v P < return reduce(source, eventual(function(value, result) {5_ ( v P @ }), initial)5_ ( v P˂ 3 return reduce(source, function(value, result) {5_ ( v Pˇ 5_ ( v Pˉ
when()5_ ( v Pˎ 5_ ( v P˒ var when = require()5_ ( v P˒ var when = require("")5_ ( v Pˣ A when(result, )5_ ( v P when(result, next, next)5_ ( v P " when(result, function(), next)5_ ( v P % when(result, function() {}, next)5_ ( v P }, next)5_ ( v P }, function())5_ ( v P }, function() {})5_ ( v P when(result, function() {5_ ( v P " when(result, function(error) {5_ ( v P 5_ ( v P next()5_ ( v P }, function() {5_ ( v P })5_ ( v P next(end, result) }, next) }, next)5_ ( v P # when(result, function(result) { next(end, result) }, next) next(end, result) }, next)5_ ( v P 5_ ( v P var end = require()5_ ( v P B var end = require("")5_ ( v P& 9 var result = reduce(source, function(value, result) {5_ ( v P* E }, initial)5_ ( v P G , console.log("########", result, value)5_ ( v P D 5_ ( ( v P ) 4 console.log(">>>>>", value, result.__result__)5_ 1 ( v P * 3 console.log(">>>>>", value, result.__proto__)5_ ( v P 5_ ( v P + - var state = next(result, value, result)5_ ( v P ( 3 console.log(">>>>>", value.__proto__, result)5_ m o n P var state = next(result)5_ Y [ Z P8 5_ @ F D L E P 6 return accumulate(source, eventual(next), initial)5_ E G F P 5 return accumulat(source, eventual(next), initial)5_ F J G P 6 return accumulate(source, eventual(next), initial)5_ G K H J
P $var accumulate = require("./reduce")5_ J K " P (var accumulate = require("./accumulate")5_ G I J H
P 'var accumulate = require("./reducible")5_ H I % P (var accumulate = require("./accumulate")5_ @ A E D P 6 return acc(function reduceReducible(next, initial) {5_ @ B D A P 6 return accumulate(source, eventual(next), initial)5_ A C B
P $var accumulate = require("./reduce")5_ B C " P (var accumulate = require("./accumulate")5_ 7 9 8 P?l 9 return reducible(function reduceSource(next, initial) {5