未在 stream.Readable 中实现 _read 的缺点

Question

我有异步数据源我想给stream.Readable 接口。然而，这个数据源没有“读取”的概念——当我有数据时，我只收到一个事件，不维护缓冲区。

那么，使用下面的实现有什么缺点吗？

stream = require 'stream'

class Wrapper extends stream.Readable
    constructor: (@resource) ->
        # call stream.Readable constructor
        super

        # when message from resource arrives
        @resource.on 'message', (message) =>
            # just push it into read queue
            @push message

        # when resource is closed
        @resource.on 'close', =>
            # indicate there will be nothing more to read
            @push null

    _read: (size) ->
        # no-op

例如如果_read 方法为空，并且数据最终会按消息推送到读取队列中，我会破坏什么吗？

Answer 1

_read() 方法用于通知您流可以处理更多数据（例如，内部缓冲区尚未达到 highWaterMark）。你当然可以忽略它。

但是，您至少应该适当地处理背压：如果 push() 返回 false，您应该停止推送，直到调用 _read() 或发出“drain”。