Pipe-io

Pipe streams and handle events.

Install

npm i pipe-io

API

pipe

Create pipe between streams and adds callback wich would be called once whenever everything is done, or error occures.

const fs = require('fs');

const pipe = require('pipe-io');
const tryToCatch = require('try-to-catch');

const NAME = 'README.md';
const NAME2 = 'README2.md';
const readStream = fs.createReadStream(NAME);
const writeStream = fs.createWriteStream(NAME2);

const [e] = await tryToCatch(pipe, [readStream, writeStream]);

Related

• Pullout - pull out data from stream

License

MIT

2020.04.14, v4.0.1

fix:

• (pipe) EACESS write error handling

feature:

• (package) nodemon v2.0.3
• (package) eslint-plugin-putout v3.5.0
• (package) nyc v15.0.1
• (package) putout v7.22.0
• (package) eslint-plugin-node v11.1.0
• (package) try-to-catch v3.0.0
• (package) pullout v4.0.0
• (package) madrun v5.4.5

2019.09.17, v4.0.0

fix:

• (pipe) error in the middle stream

feature:

• (pipe) callback -> promise

2019.09.17, v3.0.12

fix:

• (pope) error in the middle stream

feature:

• (pipe) add madrun
• (package) nyc v14.1.1

2018.11.21, v3.0.11

fix:

• (pipe) empty stream | write file error: rm pipeline (nodejs/node/issues/24517)

2018.11.14, v3.0.10

fix:

• (pipe) req|unzip|transform

feature:

• (package) pullout v3.0.0
• (package) eslint-plugin-node v8.0.0

2018.10.03, v3.0.9

fix:

• (pipe) no open event

2018.10.02, v3.0.8

feature:

• (pipe) pipeline.apply -> pipeline

2018.10.02, v3.0.7

feature:

• (pipe) add ability to use built-in pipeline
• (package) redrun v7.0.0

2018.09.20, v3.0.6

fix:

• (pipe) do not remove onWriteOpen

feature:

• (package) nyc v13.0.1

2018.08.23, v3.0.5

fix:

• (pipe) isWriteOpened

2018.08.16, v3.0.4

fix:

• (pipe) finish before error when write to file

feature:

• (package) pullout v2.0.0
• (package) eslint-plugin-node v7.0.1
• (package) eslint v5.3.0
• (package) nyc v12.0.2

2018.05.08, v3.0.3

fix:

• (pipe) file: gunzip

2018.05.05, v3.0.2

fix:

• (pipe) fs: read stream and write stream is directories

feature:

• (pipe) read error and finish -> read error and write open

2018.05.02, v3.0.1

fix:

• (pipe) readable: read.resume -> this.read

2018.05.02, v3.0.0

feature:

• (travis) add node v10
• (pipe) drop support of node < 4
• (package) redrun v6.0.0
• (package) buble v0.19.2
• (package) buble v0.18.0
• (package) buble v0.17.0
• (package) coveralls v3.0.0
• (package) buble v0.16.0

2017.08.29, v2.0.5

feature:

• (pipe) rm open

2017.08.29, v2.0.4

fix:

• (pipe) file1, file2: response

2017.08.28, v2.0.3

feature:

• (pipe) rm callWhenOpen
• (package) nyc v11.0.2
• (package) eslint v4.0.0

2017.01.20, v2.0.2

fix:

• (pipe) file1 | gunzip | untar: erro header check: gz

feature:

• (package) buble v0.15.1
• (package) nyc v10.0.0
• (package) nyc v9.0.1

2016.11.08, v2.0.1

feature:

• (pipe-io) rm getBody: use pullout for this purpose

2016.11.08, v2.0.0

feature:

• (pipe) es2015-ify

2016.11.08, v1.2.8

fix:

• (pipe) es2015 -> es5

2016.11.08, v1.2.7

fix:

• (pipe) file1 | file2: write open EACESS: big file

2016.11.08, v1.2.6

fix:

• (pipe) pipe tar | zip | file

2016.10.31, v1.2.5

fix:

• (pipe) tar | gzip | file

feature:

• (npmignore) add coverage

2016.10.27, v1.2.4

fix:

• (pipe) file1 | gunzip | untar

2016.10.27, v1.2.3

feature:

• (package) add pullout

2016.10.27, v1.2.2

feature:

• (package) nyc v8.3.2
• (package) scripts: lint
• (pipe-io) getBody -> pullout
• (ignore) add swp
• (pipe) rm iifee
• (package) scripts: watch:test
• (travis) node_js: add 7
• (travis) node: 4, 5

2015.12.21, v1.2.1

feature:

• (pipe) add coverals
• (pipe) rm writeError && readError check
• (pipe) add coverage

2015.08.17, v1.2.0

feature:

• (pipe) add ability to handle pipe from file to gunzip
• (package) tape v4.2.0

2015.04.23, v1.1.36

fix:

• (pipe) rm error.code check

2015.04.23, v1.1.35

fix:

• (pipe) crash when read and write directories

2015.04.23, v1.1.34

fix:

• (pipe) read && error -> end && error

2015.04.22, v1.1.33

fix:

• (pipe) on callback when readStream is directory

2015.04.22, v1.1.32

fix:

• (pipe) assert: options -> callback

2015.04.22, v1.1.31

fix:

• (pipe) crash when read error

2015.04.22, v1.1.30

fix:

• (pipe) call callback twice

2015.04.21, v1.1.29

fix:

• (pipe) write open: return error only when it occures

2015.04.21, v1.1.28

fix:

• (pipe) when could not open file callback do not execute

2015.04.20, v1.1.27

fix:

• (pipe) crash when try to overwrite folder

2015.04.20, v1.1.26

feature:

• (pipe) add fullPipe

2015.04.20, v1.1.25

fix:

• (pipe) readError does not handle after writeError

feature:

• (npmignore) rm

2015.03.28, v1.1.24

fix:

• (pipe) onWriteError: never finish, onReadError: never end

2015.03.27, v1.1.23

feature:

• (pipe) pipe: add rm

2015.03.27, v1.1.22

fix:

• (pipe) end && finish -> end || finish

2015.03.27, v1.1.21

feature:

• (pipe) improve error handling

2015.03.11, v1.1.20

fix:

• (pipe) rm read.pause, read.resume

2015.03.11, v1.1.19

fix:

• (pipe) add fs.WriteStream check

2015.02.25, v1.1.18

fix:

• (pipe) crash when can read but could not write

2015.02.18, v1.1.17

fix:

• (pipe) when read error do not call callback

2015.02.16, v1.1.16

feature:

• (pipe) call callback only on end

2015.02.16, v1.1.15

fix:

• (pipe) remove listeners on error

2015.02.15, v1.1.14

feature:

• (pipe) getBody: rmListeners

2015.02.15, v1.1.13

feature:

• (pipe) add unsetListeners

2015.02.15, v1.1.12

feature:

• (pipe) add once

2015.02.14, v1.1.11

fix:

• (pipe) callback called a couple times

2015.02.12, v1.1.10

feature:

• (pipe) add pause/resume

2015.02.12, v1.1.9

feature:

• (package) rm execon

2015.02.06, v1.1.8

fix:

• (pipe) getBody: readstram -> readStream

2015.02.02, v1.1.7

feature:

• (pipe) checkup -> assert

2015.01.16, v1.1.6

fix:

• (pipe) crash when no options

feature:

• (package) v1.1.5
• (package) execon v1.1.0

2015.01.15, v1.1.5

feature:

• (package) execon v1.1.0

2014.12.29, v1.1.4

fix:

• (pipe) throw when no access to write file

2014.12.01, v1.1.3

feature:

• (pipe) on -> once
• (pipe) rm duplicate listener

2014.11.25, v1.1.2

feature:

• (pipe) util-io -> execon, checkup

2014.11.21, v1.1.1

fix:

• (pipe) if error when write to file -> exeption

2014.11.3, v1.1.0

feature:

• (pipe) read, write, options, callback -> [read, write], options, callback

2014.10.31, v1.0.1

feature:

• (npmignore) add
• (gitignore) rm not neaded

2014.10.31, v1.0.0

feature:

• (pipe) pipe.create -> pipe
• (package) util-io v1.5.0