@transfast/stream-sorter

Emit sorted stream chunks, buffering the quick ones and discarding the ones that lost the train

Usage no npm install needed!

<script type="module">
  import transfastStreamSorter from 'https://cdn.skypack.dev/@transfast/stream-sorter';
</script>

README

Build Status Coverage Status Greenkeeper badge

stream-sorter

Emit sorted stream chunks, buffering the quick ones and discarding the ones that lost the train

Install

npm install stream-sorter

API

consecutive

Emit the data chunks in order, ignoring the old ones

  • options: options passed to underlying Transform stream
    • idField: fields used to store data chunk identifier
    • nextId: initial ID
    • sort: function used to compare and sort the data chunks

latest

Drop data chunks older than the latest emitted one

  • options: options passed to underlying Transform stream
    • idField: fields used to store data chunk identifier
    • lastId: initial ID
    • sort: function used to compare and sort the data chunks

start

Emit the data chunks in bytes order ignoring old ones and allowing intersections

  • options: options passed to underlying Transform stream
    • idField: fields used to store data chunk identifier
    • start: initial ID
    • sort: function used to compare and sort the data chunks