数据写入流的顺序保证与读取的顺序相同。写入流时,数据要么被写入,要么被排队,顺序不会改变。这是来自 Node.js 源代码:
function writeOrBuffer(stream, state, chunk, encoding, cb) {
chunk = decodeChunk(state, chunk, encoding);
if (util.isBuffer(chunk))
encoding = 'buffer';
var len = state.objectMode ? 1 : chunk.length;
state.length += len;
var ret = state.length < state.highWaterMark;
state.needDrain = !ret;
if (state.writing || state.corked)
state.buffer.push(new WriteReq(chunk, encoding, cb));
else
doWrite(stream, state, false, len, chunk, encoding, cb);
return ret;
}
Run Code Online (Sandbox Code Playgroud)
这也是数据事件的触发方式:
// if we want the data now, just emit it.
if (state.flowing && state.length === 0 && !state.sync) {
stream.emit('data', chunk);
stream.read(0);
}
Run Code Online (Sandbox Code Playgroud)
除非没有排队数据,否则数据事件不会触发块,这意味着您将按照传入的顺序获取数据。
| 归档时间: |
|
| 查看次数: |
1624 次 |
| 最近记录: |