Learn about our RFC process, Open RFC meetings & more.Join in the discussion! »

sorted-union-stream

3.0.1 • Public • Published

sorted-union-stream

Get the union of two sorted streams

npm install sorted-union-stream

build status

Usage

const union = require('sorted-union-stream')
const { Readable } = require('streamx')
 
// from converts an array into a stream
const sorted1 = Readable.from([1, 10, 24, 42, 43, 50, 55])
const sorted2 = Readable.from([10, 42, 53, 55, 60])
 
// combine the two streams into a single sorted stream
const u = new Union(sorted1, sorted2)
 
u.on('data', function(data) {
  console.log(data)
})
u.on('end', function() {
  console.log('no more data')
})

Running the above example will print

1
10
24
42
43
50
53
55
60
no more data

Streaming objects

If you are streaming objects sorting is based on the compare function you can pass as the 3rd argument.

const sorted1 = Readable.from([{ foo:'a' }, { foo:'b' }, { foo:'c' }])
const sorted2 = Readable.from([{ foo:'b' }, { foo:'d' }])
 
const u = new Union(sorted1, sorted2, function(a, b) {
  return a.foo < b.foo ? -1 : a.foo > b.foo ? 1 : 0 
})
 
union.on('data', function(data) {
  console.log(data)
})

Running the above will print

{ foo: 'a' }
{ foo: 'b' }
{ foo: 'c' }
{ foo: 'd' }

License

MIT

Install

npm i sorted-union-stream

DownloadsWeekly Downloads

454,267

Version

3.0.1

License

MIT

Unpacked Size

8.53 kB

Total Files

7

Last publish

Collaborators

  • avatar