Base64Stream

Base64Stream.coffee

Stream = require "stream"

class Base64Stream extends Stream

  _queue: ""

  _emitChunk: ( chunk ) ->
    @emit "data", new Buffer chunk, "base64"

  write: ( chunk ) ->
    if chunk.length % 4 != 0
      @_queue += chunk
      if @_queue.length % 4 == 0
        @_emitChunk @_queue
        @_queue = ""
    else
      @_emitChunk chunk

  end: ( chunk ) ->
    if arguments.length
      @write.apply @, arguments
    if @_queue.length
      @_emitChunk @_queue
    @emit "end"

module.exports = Base64Stream