gistfile1.coffee

Stream = require 'stream'

class CachedStream extends Stream
  constructor: ->
    @buffers = []

  readable: true
  writable: true

  write: (buffer) ->
    @buffers.push buffer
    @emit 'data', buffer

  end: ->
    @emit 'end'

  pipeCached: (dest) ->
    bufferIndex = 0

    sendData = =>
      if bufferIndex < @buffers.length
        if dest.write @buffers[bufferIndex], 'binary'
          bufferIndex += 1
          process.nextTick sendData
        else
          # write buffer is full, wait for drain to resume sending
          dest.once 'drain', sendData

      else
        dest.end()

    sendData()


module.exports = CachedStream