# mystreams

> MyStreams ====================================

Latest version **0.0.9** (published 2015-03-13) · ISC license · 0 weekly downloads

## Install

```sh
npm install mystreams
pnpm add mystreams
yarn add mystreams
bun add mystreams
```

## Health

**Score 15/100 (F)** — status: abandoned.

Positive: no vulnerabilities.

Warnings: low downloads; no types; no esm support; pre 1.0.

Negative: abandoned; low maintenance score.

## Facts

| | |
|---|---|
| Version | 0.0.9 |
| Published | 2015-03-13 |
| First published | 2015-03-06 |
| Weekly downloads | 0 |
| License | ISC |
| TypeScript types | none |
| Module format | CommonJS |
| Dependencies | 0 |
| Known vulnerabilities | 0 |
| Install scripts | no |
| Maintainers | archil |
| Keywords | stream, streams, groupby |

## Links

- npm: https://www.npmjs.com/package/mystreams
- Repository: https://github.com/Antares007/mystreams
- Issues: https://github.com/Antares007/mystreams/issues
- npm.io page: https://npm.io/package/mystreams

## Alternatives

- [byte-size](https://npm.io/package/byte-size.md) — 2.1M weekly downloads
- [speed-limiter](https://npm.io/package/speed-limiter.md) — 16.0K weekly downloads
- [@powersync/node](https://npm.io/package/@powersync/node.md) — 10.9K weekly downloads
- [@ledgerhq/coin-cardano](https://npm.io/package/@ledgerhq/coin-cardano.md) — 1.0K weekly downloads
- [@jayesol/jayeson.lib.streamfinder](https://npm.io/package/@jayesol/jayeson.lib.streamfinder.md) — 1.0K weekly downloads

## Recent versions

- 0.0.9 (latest) — 2015-03-13
- 0.0.8 — 2015-03-13
- 0.0.7 — 2015-03-07
- 0.0.5 — 2015-03-07
- 0.0.4 — 2015-03-06
- 0.0.3 — 2015-03-06
- 0.0.1 — 2015-03-06

## README

MyStreams
====================================

```shell
npm install mystreams
```


```javascript
var { streamAsyncCall, transform, splitArray, enrich, groupBy, splitKeyValue } = require('mystreams');

var git = function(cmd, parsers, cb) {
  //... 
};

streamAsyncCall(
  git, // async function
  `diff-tree --raw -r ${argv.tree1} ${argv.tree2}${argv.filter ? ' -- \'' + argv.filter + '\''  : ''}`, //arg1
  [git.mappers.parseDiffOutput] //arg2
).pipe(
  splitArray()
).pipe(
  enrich(
    [x => !!x.newSha, x => git.getBlob.bind(git, x.newSha), (err, v, x) => (x.newBlob = v, x)],
    [x => !!x.oldSha, x => git.getBlob.bind(git, x.oldSha), (err, v, x) => (x.oldBlob = v, x)]
  )
).pipe(
  // ...
).pipe(
  groupBy(x => x.key, v => v.blob)
).pipe(
  splitKeyValue()
).pipe(
  enrich([ x => true, x => git.makeTree.bind(git, x.value), (err, v, x) => (x.sha = v, x) ])
).pipe(
  groupBy(x => 'root', v => ({name: v.key, type: 'tree', sha: v.sha}))
).pipe(
  enrich([ x => true, x => git.makeTree.bind(git, x.root), (err, v, x) => (x.sha = v, x) ])
).pipe(
  transform(x => x.sha)
).pipe(
  process.stdout
);
```

---
_Source: https://npm.io/package/mystreams · Machine-readable twin of the npm.io package page. Health data is recomputed on every publish._