poelstra / ts-stream / 98 / 1

97%

master: 97%

push

travis-ci-com

Batch transform (#49)

* Batch stream function (no tests)

* Early-return chunk in case of abort

* expand batch with lower threshold and timeout features

* Lint

* some passing tests with detailed logging

* tests for timeout, refactor optional parameters to be named

* Reorganize behaviour around abort inside batch, tests for abort

* Realize that writeEach() folds abort errors into end errors

* Thoroughly test timeout clock

* simplify test

* Delog

* lint

* prettierify

* MochaDone -> Mocha.Done

* Remove stray line of code

* remove void

* remove function 'batcher' as unsure if needed

* Export batcher as a transform instead of a Stream method

* Explicitly compare timeout value to , since it could be a number (including 0) in the browser

* Simplify implementation with async/await, allow backpressure when maxBatchSize is reached, allow out-of-flow write operations to abort

* Switch launch config to bdd (it doesn't work otherwise)

* Update time-based tests to work with sinon.useFakeTimers() via clockwise()

* remove sinon clock mock test

* Shorten some tests, backpressure test

* remove accidentally copied test

* Clear any existing timeout before setting a new one

* Tests for backpressure and error bouncing

* Update test to ensure coverage

* Ensure that error within timeout flush is caught

* Replace composeEnders

* Prevent unnecessary Promise chaining as elements come in between minBatchSize and maxBatchSize

* Batcher Options

* Rewrite stream flow for clarity using 'pendingWrite' flag (credit Martin Poelstra)

* test to ensure the while loop inside earlyFlush() is doing its job

* explicitly assert that stream hasn't ended yet in while loop test

* Capture errors from early flush() and throw them on write() or end()

* Improve line coverage for Transform.ts

* Tighten up handling of failure cases (still one failing test)

* With pendingWrite tracked promis... (continued)

211 of 251 branches covered (84.06%)

2220 of 2299 relevant lines covered (96.56%)

24.58 hits per line