pull-cat

WebJar for pull-cat

License	MIT
GroupId	org.webjars.npm
ArtifactId	pull-cat
Last Version	1.1.11
Release Date	Feb 21, 2018
Type	jar
Description	pull-cat WebJar for pull-cat
Project URL	http://webjars.org
Source Code Management	https://github.com/pull-stream/pull-cat

Download pull-cat

Filename	Size
pull-cat-1.1.11.pom
pull-cat-1.1.11.jar	6 KB
pull-cat-1.1.11-sources.jar	22 bytes
pull-cat-1.1.11-javadoc.jar	22 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.webjars.npm/pull-cat/ -->
<dependency>
    <groupId>org.webjars.npm</groupId>
    <artifactId>pull-cat</artifactId>
    <version>1.1.11</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.webjars.npm/pull-cat/
implementation 'org.webjars.npm:pull-cat:1.1.11'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.webjars.npm/pull-cat/
implementation ("org.webjars.npm:pull-cat:1.1.11")

Apache Buildr

'org.webjars.npm:pull-cat:jar:1.1.11'

Apache Ivy

<dependency org="org.webjars.npm" name="pull-cat" rev="1.1.11">
  <artifact name="pull-cat" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.webjars.npm', module='pull-cat', version='1.1.11')
)

Scala SBT

libraryDependencies += "org.webjars.npm" % "pull-cat" % "1.1.11"

Leiningen

[org.webjars.npm/pull-cat "1.1.11"]

Dependencies

There are no dependencies for this project. It is a standalone project that does not depend on any other jars.

Project Modules

There are no modules declared in this project.

pull-cat

Concatenate pull-streams

Install

npm install --save pull-cat

Example

Construct a new source stream from a sequential list of source streams, reading from each one in turn until it ends, then the next, etc. If one stream errors, then the rest of the streams are aborted immediately. If the cat stream is aborted (i.e. if it's sink errors) then all the streams are aborted.

A cat stream is a moderately challenging stream to implement, especially in the context of error states.

var cat = require('pull-cat')
var pull = require('pull-stream')

pull(
  cat([
    pull.values([1,2,3]),
    pull.values([4,5,6])
  ]),
  pull.log()
)
// 1
// 2
// 3
// 4
// 5
// 6

Api

cat = require('pull-cat')

stream = cat(streams)

Reads from each stream in streams until finished.

If a stream errors, stop all the streams. if the concatenated stream is aborted, abort all the streams, then callback to the aborter.

License

MIT

Versions

Version
1.1.11 Feb 21, 2018