How to use combined-stream - 10 common examples
To help you get started, we’ve selected a few combined-stream examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
rdkmaster / rdk / test / node_modules / protractor / node_modules / request / node_modules / form-data / lib / form_data.js View on Github 
FormData.prototype.append = function(field, value, options) {
options = options || {};
// allow filename as single option
if (typeof options == 'string') {
options = {filename: options};
}
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') {
value = '' + value;
}
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter();putBlockList(request) {
let blockPaths = [];
for (const block of request.payload) {
const blockId = env.blockId(request.containerName, request.blobName, block.id);
blockPaths.push(env.diskStorageUri(blockId));
}
// Updating properties of blob
const coll = this.db.getCollection(request.containerName);
const blobProxy = this._createOrUpdateBlob(coll, request);
// Writing multiple blocks to one blob
const combinedStream = CombinedStream.create();
for (const path of blockPaths) {
combinedStream.append(fs.createReadStream(path));
}
return new BbPromise((resolve, reject) => {
const destinationStream = fs.createWriteStream(request.uri);
destinationStream
.on('error', (e) => {
reject(e);
})
.on('finish', () => {
let totalSize = 0;
// Set Blocks in DB to committed = true, delete blocks not in BlockList
const promises = [];
const blocks = coll.chain()
.find({ parentId: request.id })
.data();}) || {};
var totalChunks = FS.Utility.size(chunkInfo.keys);
function getNextStreamFunc(chunk) {
return Meteor.bindEnvironment(function (next) {
var fileKey = _fileReference(fileObj, chunk);
var chunkReadStream = FS.TempStore.Storage.adapter.createReadStream(fileKey);
next(chunkReadStream);
}, function (error) {
throw error;
});
} // Make a combined stream
var combinedStream = CombinedStream.create(); // Add each chunk stream to the combined stream when the previous chunk stream ends
var currentChunk = 0;
for (var chunk = 0; chunk < totalChunks; chunk++) {
combinedStream.append(getNextStreamFunc(chunk));
} // Return the combined stream
return combinedStream;
};
/////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////FormData.prototype.append = function(field, value, options) {
options = options || {};
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') value = ''+value;
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter(field, value, options);
append(header);FormData.prototype.append = function(field, value, options) {
options = options || {};
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') value = ''+value;
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter(field, value, options);
append(header);FormData.prototype.append = function(field, value, options) {
options = options || {};
// allow filename as single option
if (typeof options == 'string') {
options = {filename: options};
}
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') {
value = '' + value;
}
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter();FormData.prototype.append = function(field, value, options) {
options = options || {};
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') value = ''+value;
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter(field, value, options);
append(header);
append(value);
append(footer);
// pass along options.knownLength
this._trackLength(header, value, options);
};FormData.prototype.append = function(field, value, options) {
options = (typeof options === 'string')
? { filename: options }
: options || {};
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') value = ''+value;
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter(field, value, options);
append(header);FormData.prototype.append = function(field, value) {
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') value = ''+value;
var header = this._multiPartHeader(field, value);
var footer = this._multiPartFooter(field, value);
append(header);
append(value);
append(footer);
this._trackLength(header, value)
};FormData.prototype.append = function(field, value, options) {
options = options || {};
// allow filename as single option
if (typeof options == 'string') {
options = {filename: options};
}
var append = CombinedStream.prototype.append.bind(this);
// all that streamy business can't handle numbers
if (typeof value == 'number') {
value = '' + value;
}
// https://github.com/felixge/node-form-data/issues/38
if (util.isArray(value)) {
// Please convert your array into string
// the way web server expects it
this._error(new Error('Arrays are not supported.'));
return;
}
var header = this._multiPartHeader(field, value, options);
var footer = this._multiPartFooter();combined-stream
A stream that emits multiple other streams one after another.
