Please enable JavaScript to use RhodeCode Enterprise
Commit Description:
fix wrong merge
Commit Description:
fix wrong merge
'use strict' ;
var utils = require ( '../utils' );
var GenericWorker = require ( './GenericWorker' );
/**
* A worker which calculate the total length of the data flowing through.
* @constructor
* @param {String} propName the name used to expose the length
*/
function DataLengthProbe ( propName ) {
GenericWorker . call ( this , "DataLengthProbe for " + propName );
this . propName = propName ;
this . withStreamInfo ( propName , 0 );
}
utils . inherits ( DataLengthProbe , GenericWorker );
/**
* @see GenericWorker.processChunk
*/
DataLengthProbe . prototype . processChunk = function ( chunk ) {
if ( chunk ) {
var length = this . streamInfo [ this . propName ] || 0 ;
this . streamInfo [ this . propName ] = length + chunk . data . length ;
}
GenericWorker . prototype . processChunk . call ( this , chunk );
};
module . exports = DataLengthProbe ;
Site-wide shortcuts
/
Use quick search box
g h
Goto home page
g g
Goto my private gists page
g G
Goto my public gists page
n r
New repository page
n g
New gist page
Repositories
g s
Goto summary page
g c
Goto changelog page
g f
Goto files page
g F
Goto files page with file search activated
g p
Goto pull requests page
g o
Goto repository settings
g O
Goto repository permissions settings
