'use strict'; var ERR_INVALID_OPT_VALUE = require('../../../errors').codes.ERR_INVALID_OPT_VALUE; function highWaterMarkFrom(options, isDuplex, duplexKey) { return options.highWaterMark != null ? options.highWaterMark : isDuplex ? options[duplexKey] : null; } function getHighWaterMark(state, options, duplexKey, isDuplex) { var hwm = highWaterMarkFrom(options, isDuplex, duplexKey); if (hwm != null) { if (!(isFinite(hwm) && Math.floor(hwm) === hwm) || hwm < 0) { var name = isDuplex ? duplexKey : 'highWaterMark'; throw new ERR_INVALID_OPT_VALUE(name, hwm); } return Math.floor(hwm); } // Default value return state.objectMode ? 16 : 16 * 1024; } module.exports = { getHighWaterMark: getHighWaterMark };
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
async_iterator.js | File | 5.82 KB | 0644 |
|
buffer_list.js | File | 6.19 KB | 0644 |
|
destroy.js | File | 3.04 KB | 0644 |
|
end-of-stream.js | File | 3.03 KB | 0644 |
|
from-browser.js | File | 101 B | 0644 |
|
from.js | File | 3.06 KB | 0644 |
|
pipeline.js | File | 2.37 KB | 0644 |
|
state.js | File | 749 B | 0644 |
|
stream-browser.js | File | 49 B | 0644 |
|
stream.js | File | 36 B | 0644 |
|