sorted-merge-stream

KO | EN

gitlite — search

#javascript #react #ai #llm #golang #rust #docker #windows #vue #pytorch #security #ios #mcp #openai

sorted-merge-stream

(★ 4)

Merge two sorted streams

sorted-merge-stream Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# sorted-merge-stream

Merge two sorted streams.

[![Build Status](https://travis-ci.org/cshum/sorted-merge-stream.svg?branch=master)](https://travis-ci.org/cshum/sorted-merge-stream)

```
npm install sorted-merge-stream
```

Shamelessly taken from [sorted-union-stream](https://github.com/mafintosh/sorted-union-stream) with slight modifications, where values with repeated key are also emitted.

### merge(streamA, streamB, [toKey], [options])
Merge two lexicographically sorted streams.

* By default keys are mapped by `value.key` or `value` itself. 
* Add a `toKey` function if you need custom key mapping. 
* Use `options.reverse = true` for reverse order.

```js
var merge = require('sorted-merge-stream')

var from = require('from2')
var a = from.obj(['a', 'b', 'd', 'e', 'g', 'h'])
var b = from.obj(['b', 'c', 'f'])

var stream = merge(a, b)

stream.pipe(...)

// 'a', 'b', 'b', 'c', 'd', 'e', 'f', 'g', 'h'
```

Merging multiple streams, custom key mapping, reverse order:

```js
var merge = require('sorted-merge-stream')

var from = require('from2')
var a = from.obj([{id: 6}, {id: 3}, {id: 1}])
var b = from.obj([{id: 6}, {id: 2}, {id: 1}])
var c = from.obj([{id: 6}, {id: 5}, {id: 3}])

function toKey (data) {
  return data.id
}

var stream = [a, b, c].reduce(function (a, b) {
  return merge(a, b, toKey, {reverse: true})
})

stream.pipe(...)

// {id: 6}, {id: 6}, {id: 6}, {id: 5}, {id: 3}, {id: 3}, {id: 2}, {id: 1}, {id: 1}
```

## License

MIT

sorted-merge-stream

sorted-merge-stream Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

sorted-merge-stream

sorted-merge-stream Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README