# File lib/taps/data_stream.rb, line 261
  def buffer_limit
    if state[:last_fetched] and state[:last_fetched] < state[:filter] and self.buffer.size == 0
      state[:last_fetched]
    else
      state[:filter]
    end
  end