stream-to-pull-stream

WebJar for stream-to-pull-stream

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

Download stream-to-pull-stream

Filename	Size
stream-to-pull-stream-1.7.2.pom
stream-to-pull-stream-1.7.2.jar	12 KB
stream-to-pull-stream-1.7.2-sources.jar	22 bytes
stream-to-pull-stream-1.7.2-javadoc.jar	22 bytes

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/org.webjars.npm/stream-to-pull-stream/ -->
<dependency>
    <groupId>org.webjars.npm</groupId>
    <artifactId>stream-to-pull-stream</artifactId>
    <version>1.7.2</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/org.webjars.npm/stream-to-pull-stream/
implementation 'org.webjars.npm:stream-to-pull-stream:1.7.2'

Gradle Kotlin

// https://jarcasting.com/artifacts/org.webjars.npm/stream-to-pull-stream/
implementation ("org.webjars.npm:stream-to-pull-stream:1.7.2")

Apache Buildr

'org.webjars.npm:stream-to-pull-stream:jar:1.7.2'

Apache Ivy

<dependency org="org.webjars.npm" name="stream-to-pull-stream" rev="1.7.2">
  <artifact name="stream-to-pull-stream" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='org.webjars.npm', module='stream-to-pull-stream', version='1.7.2')
)

Scala SBT

libraryDependencies += "org.webjars.npm" % "stream-to-pull-stream" % "1.7.2"

Leiningen

[org.webjars.npm/stream-to-pull-stream "1.7.2"]

Dependencies

compile (2)

Group / Artifact	Type	Version
org.webjars.npm » looper	jar	[3.0.0,4)
org.webjars.npm : pull-stream	jar	[3.2.3,4)

Project Modules

There are no modules declared in this project.

stream-to-pull-stream

Convert a classic-stream, or a new-stream into a pull-stream

example

var toPull = require('stream-to-pull-stream')
var pull = require('pull-stream')

pull(
  toPull.source(fs.createReadStream(__filename)),
  pull.map(function (e) { return e.toString().toUpperCase() }),
  toPull.sink(process.stdout, function (err) {
    if(err) throw err
    console.log('done')
  })
)

if the node steam is a duplex (i.e. net, ws) then use toPull.duplex(stream, cb?) duplex takes an optional callback in the same way that sink does.

License

MIT

Versions

Version
1.7.2 Feb 21, 2018