All Versions
35
Latest Version
Avg Release Cycle
93 days
Latest Release
2087 days ago
Changelog History
Page 4
Changelog History
Page 4
-
v2.7.0 Changes
๐ Broken release. Use
2.7.1
instead. -
v2.6.0 Changes
๐ Bugfix
parallel
no longer drops elements on the floor in a number of cases. #302, #331. Fixes #234, #328.- Calling
next
beforepush
within a generator stream no longer causes the stream to resume and throw away data when used withpull
. #326. Fixes #325. - Parallel no longer drops data if paused. #331. Fixes #328.
- ๐ Various grammar fixes and documentation updates. #341, #354, #381, #397, #407
isStream
now always returns a boolean. Before, it would returnundefined
if the argument was an object but not a Highland stream. #343.- Streams now unpipe from Readable on destroy. #361.
_send
now keeps a reference to the correct consumer/observer array. #367. Fixes #366.- Streams constructed with
pipeline
now correctly exert backpressure. #372, #377. Also fixes an possible issue with not consuming errors from promises. #391. - It is no longer possible to re-enter the consume callback. #393.
๐ New additions
- ๐
mergeWithLimit
: Likemerge
, but with an argument to specify the maximum number of parallel stream that can be consumed at once. #375. - ๐ minified build: There is now a minified version of the browser build under
dist/highland.min.js
. #392. wrapCallback
: The function now takes a second argument (mappingHint
) that describes how arguments passed to the callback are handled. It behaves like themappingHint
parameter of the stream constructor. #247. Fixes #246, #334.- ๐ Node 4 and 5: Added support for node 4 and 5. #383.
๐ Improvements
- The runtime of
pick
per object is nowO(n)
, wheren
is the number of properties to be picked. It was previouslyO(mn)
, wherem
is the number of pickable properties on the object. #286. - Both
pick
andpickBy
can now select non-enumerable keys. #286. parallel
now throws descriptive errors if it encounters a value that is not a stream. #318.- ๐ป The standalone Highland file is now built using Browserify 12.0.1.
- โก๏ธ Updates a number of
devDependencies
. If you develop on Highland, make sure to update the dependencies. #384, #385, #387, #390, #400, #403, #415. uniq
now uses a Set to compute uniqueness whenever available, resulting in a significant performance boost for large streams. The definition of equality is still===
, not theSameValueZero
algorithm used bySet
. #395parallel
now throws if provided an argument that is not a number. #421.
Other
- โฌ๏ธ Dropped support for Node 0.11.
- โฌ๏ธ Dropped support for iojs.
- ๐ Deprecation warnings for API changes upcoming in version 3.0.0 have been added. #417
-
v2.5.1 Changes
๐ Bugfix
- ๐ Move stream check in constructor to beginning of object branch. #303
-
v2.5.0 Changes
๐ New additions
drop
: Ignores the firstn
values of a stream and then emits the rest. #75 #244done
: Calls the supplied function once the stream has ended. #161sort
: Collects all values together then emits each value individually but in sorted order. #169 #245streamifyAll
: Takes an object or a constructor function and returns that object or constructor with streamified versions of its function properties. #226- ๐
Iterator
Support: ECMA2015 (aka ES6) style iterators can now be passed to the Highland constructor function. #235 slice
: Creates a new stream with the values from the source in the range of specified in thestart
andend
parameters. #250batchWithTimeOrCount
: Takes one Stream and batches incoming data within a maximum time frame into arrays of a maximum length. #284
๐ Improvements
each
now returns an empty stream rather than nothing. #161.- Ensure
through
propagates Node stream errors. #240 - Preserve
this
context of wrapped function when usingwrapCallback
. #248 - โก๏ธ Update
tranduce
to use latest version of transformer protocol. #261
-
v2.0.0 Changes
- ๐ The
source.merge()
algorithm now evaluates the entire source stream before reading from all of the resulting streams in parallel (previously it would start reading as soon as the source emitted the next stream) - ๐ The
merge()
function now attempts to balance inputs more fairly. For example, if stream A has 100 values buffered and stream B gets a new value after 100ms, if we read at 200ms we'll get a value from each stream. Previously it would exhaust the stream A buffer before reading from stream B.
- ๐ The