def handleSubscriptions(app, socketio):
eventHandler = SubscriptionEventHandler(app, socketio)
while True:
try:
if app.sessionForSubscriptions is None:
app.sessionForSubscriptions = openBloombergSession()
app.allSubscriptions = {}
event = app.sessionForSubscriptions.nextEvent(500)
eventHandler.processEvent(event, app.sessionForSubscriptions)
except Exception as e:
traceback.print_exc()
handleBrokenSession(app, e)
eventlet.sleep(1)
finally:
eventlet.sleep()
评论列表
文章目录