摘要：回調(diào)函數(shù)將接收到一個對象。要禁止這一默認行為，選項應該指定為。一般來說，建議開發(fā)人員避免使用事件和方法，使用或事件代替。事件在寫入數(shù)據(jù)出錯或者使用管道出錯時觸發(fā)，事件發(fā)生時，回調(diào)函數(shù)僅會接收到一個參數(shù)。注意事件發(fā)生時，流并不會關(guān)閉。

流可以是可讀的、可寫的、或者是可讀寫的。所有的流都是EventEmitter的實例。

所有使用Node.js API創(chuàng)建的流對象都只能操作strings和Buffer（或Unit8Array）。但是一些第三方流的實現(xiàn)，能夠操作其他類型的javascript值（除了null，它在流處理中有特殊意義），這種類型的流被認為是工作在‘對象模式’

Writable和Readable流都會將數(shù)據(jù)存儲到內(nèi)部的緩存（buffer）中

可讀流的實現(xiàn)調(diào)用stream.push(chunk)時，數(shù)據(jù)被放到緩存中。如果流的消費者沒有調(diào)用stream.read()方法，就會始終存在于內(nèi)部隊列中，直到被消費。緩存的大小取決于傳遞給流構(gòu)造函數(shù)的highWaterMark選項。當內(nèi)部可讀緩存的大小達到highWaterMark指定的閥值時，流會暫停從底層資源讀取數(shù)據(jù)，直到當前緩存的數(shù)據(jù)被消費。

可寫流通過反復調(diào)用writable.write(chunk)方法將數(shù)據(jù)放到緩存。當內(nèi)部可寫緩存的總大小小于highWaterMark指定的閥值時，調(diào)用writable.write()返回true，一旦達到或超過highWaterMark，調(diào)用writable.write()返回false，此時應該停止向流中寫入數(shù)據(jù)，直到drain事件被觸發(fā)。

例如fs.createReadStream()

可讀流（Readable streams）是對提供數(shù)據(jù)的源頭（source）的抽象

兩種工作模式：flowing（流動模式）和paused（暫停模式）

flowing模式下：可讀流自動從系統(tǒng)底層讀取數(shù)據(jù)，并通過EventEmitter()接口的事件盡快將數(shù)據(jù)提供給應用。

paused模式下：必須顯式調(diào)用stream.read()方法來從流中讀取數(shù)據(jù)片段。

初始工作模式都是paused的Readable流，可以通過三種途徑切換到flowing模式。

監(jiān)聽data事件

調(diào)用stream.resume()方法

調(diào)用stream.pipe()方法將數(shù)據(jù)發(fā)送到Writable

可讀流可以通過兩種方式切換到paused

如果可讀流沒有橋接可寫流成為管道，調(diào)用stream.pause()實現(xiàn)

如果可讀流橋接了若干可寫流組成了管道，通過取消data事件監(jiān)聽，并調(diào)用stream.unpipe()方法移除所有管道目標實現(xiàn)

close事件：

在流或其底層資源（比如一個文件）關(guān)閉后觸發(fā)。事件觸發(fā)后，該流將不會再觸發(fā)任何事件。

data事件：

在流將數(shù)據(jù)傳遞給消費者時觸發(fā)。當流轉(zhuǎn)換到flowing模式時會觸發(fā)該事件。處理器的參數(shù)是Buffer對象，如果你調(diào)用了Readable的setEncoding(encoding)方法，處理器的參數(shù)就是String對象。

end事件：

在流中再沒有數(shù)據(jù)可供消費時觸發(fā)。

const readable = readableStreamSomehow()
readable.on("data", (chunk) => {
    console.log(`received ${chunk.length} bytes of buffer data.`)
})
readable.on("end", () => {
    console.log("no more data.")
})

error事件：

通常底層系統(tǒng)內(nèi)部出錯從而不能產(chǎn)生數(shù)據(jù)，或當流的實現(xiàn)試圖傳遞錯誤數(shù)據(jù)時發(fā)生?；卣{(diào)函數(shù)將接收到一個Error對象。

readable事件：

將在流中有數(shù)據(jù)可供讀取時觸發(fā)。stream.read()返回可用的數(shù)據(jù)。

const readable = readableStreamSomehow()
readable.on("readable", () => {
    // 有一些數(shù)據(jù)可讀
})

在到達流數(shù)據(jù)尾部時，該事件也會觸發(fā)。觸發(fā)順序在end事件之前。stream.read()返回null

// foo.txt是一個空文件
const fs = require("fs")
const rr = fs.createReadStream("foo.txt")
rr.on("readable", () => {
    console.log("readable", rr.read) // null
})
rr.on("end", () => {
    console.log("end") // end
})

readable.pipe(destination[,options])：

綁定一個writable到readable上，形成一個管道，并將所有數(shù)據(jù)傳給綁定的writable?？梢栽趩蝹€可讀流上綁定多個可寫流。

const r = fs.createReadStream("file.txt")
const z = zlib.createGzip()
const w = fs.createWriteStream("file.txt.gz")
r.pipe(z).pipe(w)

默認情況下，當源可讀流觸發(fā)end事件時，目標流也會調(diào)用stream.end()方法從而結(jié)束寫入。要禁止這一默認行為，end選項應該指定為false。

reader.pipe(writer, {end: false})
reader.on("end", () => {
    writer.end("goodbye)
})

如果可讀流在處理時發(fā)生錯誤，目標可寫流不會自動關(guān)閉。 如果發(fā)生錯誤，需要手動關(guān)閉所有流以避免內(nèi)存泄漏。

一般來說，建議開發(fā)人員避免使用"readable"事件和readable.read()方法，使用readable.pipe()或"data"事件代替。

writable.unpipe([destination])：

readable.unpipe()方法將之前通過stream.pipe()方法綁定的流分離

如果 destination 沒有傳入, 則所有綁定的流都會被分離.

如果傳入 destination, 但它沒有被pipe()綁定過，則該方法不作為.

例如fs.createWriteStream()

Writable streams是destination的一種抽象，這種destination允許數(shù)據(jù)寫入

close事件：

在流或者底層資源（比如一個文件）關(guān)閉后觸發(fā)，事件觸發(fā)后該流將不會再觸發(fā)任何事件。

drain事件`：

如果調(diào)用stream.write(chunk)方法返回false，流將在適當?shù)臅r機觸發(fā)drain事件，這時才可以繼續(xù)向流中寫入數(shù)據(jù)。

error事件`：

在寫入數(shù)據(jù)出錯或者使用管道（pipe）出錯時觸發(fā)，事件發(fā)生時，回調(diào)函數(shù)僅會接收到一個Error參數(shù)。注意：error事件發(fā)生時，流并不會關(guān)閉。

finish事件：

在調(diào)用了stream.end()方法，且緩沖區(qū)數(shù)據(jù)都已經(jīng)傳給底層系統(tǒng)之后，finish事件將被觸發(fā)。

pipe事件：

在可讀流上調(diào)用stream.pipe()方法，并在目標流向中添加當前可寫流時，將會在可寫流上觸發(fā)pipe事件。

const writer = writeStreamSomehow()
const reader = readStreamSomehow()
writer.on("pipe", (src) => {
    console.log("piping into the writer")
    assert.equal(src, reader)
})
reader.pipe(writer)

writable.end([chunk][,encoding][,callback])：

調(diào)用writable.end()方法表明接下來沒有數(shù)據(jù)要被寫入writable，通過傳入可選的chunk和encoding參數(shù)，可以在關(guān)閉流之前再寫入一段數(shù)據(jù)。如果傳入了可選的callback函數(shù)，將作為finish事件的回掉函數(shù)。

在調(diào)用了stream.end()方法之后，再調(diào)用stream.write()方法會導致錯誤。

// 寫入hello 并用world結(jié)束寫入
const file = fs.createWriteStream("example.txt)
file.write("hello, ")
file.end("wrold!)
// 后面不允許再寫入數(shù)據(jù)

writable.write(chunk[,encoding][,callback])：

向流中寫入數(shù)據(jù)，并在數(shù)據(jù)處理完成后調(diào)用callback。我們建議，一旦write()返回false，在"drain"事件觸發(fā)前，不能寫入任何數(shù)據(jù)塊。

writable.uncork()

例如net.Socket()

例如zlib.createDeflate()