Class: RatProto::Commands::Stream

Inherits:
Base
  • Object
show all
Defined in:
lib/ratproto/commands/stream.rb

Constant Summary collapse

OPERATION_TYPES = 
%w[create update delete].freeze

Constants inherited from Base

Base::DID_REGEXP, Base::HANDLE_REGEXP, Base::NSID_REGEXP

Instance Method Summary collapse

Instance Method Details

#execute ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/ratproto/commands/stream.rb', line 46

def execute
  require 'skyfall'

  prepare_filters

  @sky = build_stream
  configure_interrupt_handler

  if print_cursor?
    @sky.on_message do |msg|
      print_cursor_and_stop(msg)
      next
    end

    @sky.connect
  else
    configure_callbacks
    @sky.connect

    log "Stopped stream at cursor #{@sky.cursor}" + (@last_timestamp ? " (#{@last_timestamp})" : "")
  end
end