A stream you can pull data from.
Tired of getting a firehose worth of data from your streams. This module is here to save the day. PullStream allows you to pull data when you want and as much as you want.
var PullStream = require'pullstream';var fs = require'fs';var ps = ;var loremIpsumStream = fscreateReadStream'loremIpsum.txt';var outputStream = fscreateWriteStreampathjoin__dirname 'loremIpsum.out';loremIpsumStreampipeps;// pull 5 bytespspull5console.logdatatoString'utf8';//synchronously pull 1000 bytes or howevery many bytes are availablevar bytes = pspullUpTo1000;// pipe the next 100 to a filepspipe100 outputStreamon'end'console.log'all done';;;
Calls a callback when the specified number of bytes are ready. If no number is specified pull will read until the end of the input stream.
- number (optional) - Number of bytes to wait for. If not specified reads to the end of input stream.
- callback(err, data) - Callback called when the bytes are ready. data is a buffer containing the bytes.
var ps = ;pspull5console.logdatatoString'utf8';;
Synchronously returns the specified number of bytes or however many bytes are available from the input stream. If no number is specified pullUpTo will return however many bytes are available from the input stream.
- number (optional) - Number of bytes to read from the input stream.
var ps = ;var data = pspullUpTo1000;console.logdatatoString'utf8';
Pipes the specified number of bytes to destStream. If a number is not specified pipe will pipe the remainder of the input stream to destStream. Back-pressure is properly managed.
- number (optional) - Number of bytes to pipe. If not specified pipe the rest of input stream.
- destStream - The stream to pipe data to.
var ps = ;var outputStream = fscreateWriteStreampathjoin__dirname 'loremIpsum.out';pspipe100 outon'end'console.log'done with pipe';;
Consume the specified number of bytes and send them to nowhere. Also drains from upstream as necessary if the specified number of bytes is less than the length of the pull stream's internal buffer.
var ps = ;psdrain5console.log'5 bytes removed from pull stream';;
Writes data to input side of a pull stream.
- data - Buffer or string to write to the input side of the pull stream.
- encoding (optional) - Encoding to use if data is a string. If not specified 'utf8' is used.
var ps = ;pspull5console.logdatatoString'ascii';;pswrite'Hello World' 'ascii';
Manually ends a pull stream.
var ps = ;pspull5console.logdatatoString'utf8';;pswrite'Hello World';psend;
Writes data to the front of the input side of a pull stream.
var ps = ;pspull11console.logdatatoString;;pswrite'World';psprepend'Hello ';psend;
(The MIT License)
Copyright (c) 2012 - 2013 Near Infinity Corporation
Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.