Method: MoSQL::Streamer#optail

Defined in:
lib/mosql/streamer.rb

#optail ⇒ Object 



148
149
150
151
152
153
154
155
156
157
 
# File 'lib/mosql/streamer.rb', line 148

def optail
  tailer.tail_from(options[:tail_from] ?
                   BSON::Timestamp.new(options[:tail_from].to_i, 0) :
                   nil)
  until @done
    tailer.stream(1000) do |op|
      handle_op(op)
    end
  end
end