             assert d.v is v
             v++
             stream.push d
-          # Mark all future ops on the stream to go straight to the stream.
-          queue = null
 
     # Callback called with (err, {v, data})
     fetch: (cName, docName, callback) ->

      # that is any better than the buffer implementation in nodejs streams themselves.
      stream._read = ->

      opChannel = getDocOpChannel cName, docName
      redisObserver = redisLib.createClient redis.port, redis.host, redis.options

      open = true

            if Math.random() < 0.4
              snapshotDb.setSnapshot cName, docName, {v:opData.v, data:doc} unless snapshotDb.closed

    _subscribe: (channel, callback) -> # Subscribe to a redis pubsub channel and get a nodejs stream out
      stream = new Readable objectMode:yes

      # This function is for notifying us that the stream is empty and needs data.
