lib/ig_markets/streaming/account_state.rb
def process_queued_data
        loop do
          send(*@data_queue.pop)

          break if @data_queue.empty?
        end

        update_market_subscriptions
      end
# Processes all queued data and updates {#accounts}, {#positions} and {#working_orders} accordingly. If there are
# no queued data updates then this method blocks until at least one data update is available.
Processes all queued data and updates {#accounts}, {#positions} and {#working_orders} accordingly. If there are
no queued data updates then this method blocks until at least one data update is available.
Processes all queued data and updates { #accounts } { #positions } and { #working_orders } accordingly . If there are no queued data updates then this method blocks until at least one data update is available .
def process_queued_data
        loop do
          send(*@data_queue.pop)
          break if @data_queue.empty?
        end
        update_market_subscriptions
      end
def process_queued_data loop do send ( * @data_queue . pop ) break if @data_queue . empty? end update_market_subscriptions end
Processes all queued data and updates {#accounts}, {#positions} and {#working_orders} accordingly.
Processes all queued data and updates { #accounts } { #positions } and { #working_orders } accordingly .