# ---------------------------------------
import clr
import sys
sys.path.append(iqfeed_dll_path)
clr.AddReference('IQFeed.CSharpApiClient')
from IQFeed.CSharpApiClient import IQFeedLauncher
IQFeedLauncher.Start(configreader.get('iqfeed_credentials', 'login'),
                     configreader.get('iqfeed_credentials', 'password'),
                     configreader.get('iqfeed_credentials', 'product_id'))
from IQFeed.CSharpApiClient.Streaming.Level2 import Level2ClientFactory
import time
# Create Level2 client
l2StreamingClient = Level2ClientFactory.CreateNew()
# Connect
l2StreamingClient.Connect()
# Level 1 handler function
def l2UpdateSummaryHandler(msg):
    print(msg)
# Subscribe to Update events
l2StreamingClient.Update += l2UpdateSummaryHandler
l2StreamingClient.Summary += l2UpdateSummaryHandler
l2StreamingClient.Error  +=l2UpdateSummaryHandler
# Request streaming
l2StreamingClient.ReqWatch('RGLD')
# Wait.....
while True:
    time.sleep(1)