end-of-stream

WebJar for end-of-stream

License	MIT
GroupId	org.webjars.npm
ArtifactId	end-of-stream
Last Version	1.4.4
Release Date	Sep 28, 2019
Type	jar
Description	end-of-stream WebJar for end-of-stream
Project URL	http://webjars.org
Source Code Management	https://github.com/mafintosh/end-of-stream

Download end-of-stream

Filename	Size
end-of-stream-1.4.4.pom
end-of-stream-1.4.4.jar	4 KB
end-of-stream-1.4.4-sources.jar	22 bytes
end-of-stream-1.4.4-javadoc.jar	22 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.webjars.npm/end-of-stream/ -->
<dependency>
    <groupId>org.webjars.npm</groupId>
    <artifactId>end-of-stream</artifactId>
    <version>1.4.4</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.webjars.npm/end-of-stream/
implementation 'org.webjars.npm:end-of-stream:1.4.4'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.webjars.npm/end-of-stream/
implementation ("org.webjars.npm:end-of-stream:1.4.4")

Apache Buildr

'org.webjars.npm:end-of-stream:jar:1.4.4'

Apache Ivy

<dependency org="org.webjars.npm" name="end-of-stream" rev="1.4.4">
  <artifact name="end-of-stream" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.webjars.npm', module='end-of-stream', version='1.4.4')
)

Scala SBT

libraryDependencies += "org.webjars.npm" % "end-of-stream" % "1.4.4"

Leiningen

[org.webjars.npm/end-of-stream "1.4.4"]

Dependencies

compile (1)

Group / Artifact	Type	Version
org.webjars.npm : once	jar	[1.4.0,2)

Project Modules

There are no modules declared in this project.

end-of-stream

A node module that calls a callback when a readable/writable/duplex stream has completed or failed.

npm install end-of-stream

Usage

Simply pass a stream and a callback to the eos. Both legacy streams, streams2 and stream3 are supported.

var eos = require('end-of-stream');

eos(readableStream, function(err) {
  // this will be set to the stream instance
	if (err) return console.log('stream had an error or closed early');
	console.log('stream has ended', this === readableStream);
});

eos(writableStream, function(err) {
	if (err) return console.log('stream had an error or closed early');
	console.log('stream has finished', this === writableStream);
});

eos(duplexStream, function(err) {
	if (err) return console.log('stream had an error or closed early');
	console.log('stream has ended and finished', this === duplexStream);
});

eos(duplexStream, {readable:false}, function(err) {
	if (err) return console.log('stream had an error or closed early');
	console.log('stream has finished but might still be readable');
});

eos(duplexStream, {writable:false}, function(err) {
	if (err) return console.log('stream had an error or closed early');
	console.log('stream has ended but might still be writable');
});

eos(readableStream, {error:false}, function(err) {
	// do not treat emit('error', err) as a end-of-stream
});

License

MIT

Related

end-of-stream is part of the mississippi stream utility collection which includes more useful stream modules similar to this one.

Versions

Version
1.4.4 Sep 28, 2019
1.4.2 Sep 24, 2019
1.4.1 Feb 13, 2018
1.1.0 Jun 16, 2016
1.0.0 Aug 29, 2015
0.1.5 Mar 21, 2016