slice-stream

WebJar for slice-stream

License	MIT
GroupId	org.webjars.npm
ArtifactId	slice-stream
Last Version	1.0.0
Release Date	Mar 12, 2020
Type	jar
Description	slice-stream WebJar for slice-stream
Project URL	https://www.webjars.org
Source Code Management	https://github.com/EvanOxfeld/slice-stream

Download slice-stream

Filename	Size
slice-stream-1.0.0.pom
slice-stream-1.0.0.jar	5 KB
slice-stream-1.0.0-sources.jar	22 bytes
slice-stream-1.0.0-javadoc.jar	22 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.webjars.npm/slice-stream/ -->
<dependency>
    <groupId>org.webjars.npm</groupId>
    <artifactId>slice-stream</artifactId>
    <version>1.0.0</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.webjars.npm/slice-stream/
implementation 'org.webjars.npm:slice-stream:1.0.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.webjars.npm/slice-stream/
implementation ("org.webjars.npm:slice-stream:1.0.0")

Apache Buildr

'org.webjars.npm:slice-stream:jar:1.0.0'

Apache Ivy

<dependency org="org.webjars.npm" name="slice-stream" rev="1.0.0">
  <artifact name="slice-stream" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.webjars.npm', module='slice-stream', version='1.0.0')
)

Scala SBT

libraryDependencies += "org.webjars.npm" % "slice-stream" % "1.0.0"

Leiningen

[org.webjars.npm/slice-stream "1.0.0"]

Dependencies

compile (1)

Group / Artifact	Type	Version
org.webjars.npm : readable-stream	jar	[1.0.31,1.1)

Project Modules

There are no modules declared in this project.

slice-stream

Pipe data through a stream until some fixed length is reached, then callback.

Installation

$ npm install slice-stream

Quick Example

End stream once a fixed length has been reached

var SliceStream = require('../');
var streamBuffers = require("stream-buffers");

var ss = new SliceStream({ length: 5}, function (buf, sliceEnd, extra) {
  if (!sliceEnd) {
    return this.push(buf);
  }
  this.push(buf);
  return this.push(null); //signal end of data
});

var sourceStream = new streamBuffers.ReadableStreamBuffer();
sourceStream.put("Hello World");
var writableStream = new streamBuffers.WritableStreamBuffer();

sourceStream
  .pipe(ss)
  .pipe(writableStream)
  .once('close', function () {
    var str = writableStream.getContentsAsString('utf8');
    console.log('First 5 bytes piped:', "'" + str + "'");
    sourceStream.destroy();
  });

//Output
//Piped data before pattern occurs: 'Hello'

License

MIT

Versions

Version
1.0.0 Mar 12, 2020