Method: Mchat::Store#message_loop_reader

Defined in:
lib/mchat/store.rb

#message_loop_reader ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/mchat/store.rb', line 60

def message_loop_reader
  get_store
  thx = Thread.new {
    while @store_messages_reader_run do
      @store.transaction do
        messages = @store[@field_name]
        messages.each do |m|
        end
        # puts m
        if block_given?
          yield(messages)
        end
        @store[@field_history_name] += messages
        @store[@field_name] = []
      end
      sleep @store_sync_time
    end
  }

  if(!@store_async_flag)
    thx.join
  end

  return thx
end