lib/ig_markets/streaming/market_subscription_manager.rb
def create_missing_subscriptions(epics)
        new_subscriptions = []

        epics.each do |epic|
          next if @subscriptions.key? epic

          subscription = @dealing_platform.streaming.build_markets_subscription epic
          subscription.on_data(&method(:run_callbacks))

          @subscriptions[epic] = subscription

          new_subscriptions << subscription
        end

        @dealing_platform.streaming.start_subscriptions new_subscriptions, snapshot: true
      end
# Initializes this market subscription manager with the specified dealing platform.
#
# @param [DealingPlatform] dealing_platform The dealing platform.
Initializes this market subscription manager with the specified dealing platform.
Initializes this market subscription manager with the specified dealing platform .
def create_missing_subscriptions(epics)
        new_subscriptions = []
        epics.each do |epic|
          next if @subscriptions.key? epic
          subscription = @dealing_platform.streaming.build_markets_subscription epic
          subscription.on_data(&method(:run_callbacks))
          @subscriptions[epic] = subscription
          new_subscriptions << subscription
        end
        @dealing_platform.streaming.start_subscriptions new_subscriptions, snapshot: true
      end
def create_missing_subscriptions ( epics ) new_subscriptions = [ ] epics . each do | epic | next if @subscriptions . key? epic subscription = @dealing_platform . streaming . build_markets_subscription epic subscription . on_data ( & method ( :run_callbacks ) ) @subscriptions [ epic ] = subscription new_subscriptions << subscription end @dealing_platform . streaming . start_subscriptions new_subscriptions , snapshot : true end
Initializes this market subscription manager with the specified dealing platform.
Initializes this market subscription manager with the specified dealing platform .
epics
dealing_platform The dealing platform.
dealing_platform The dealing platform .