#NEWLINE# def start( self , ignore_heartbeat = True , **params ) : #NEWLINE# #INDENT# ' Starts the stream with the given parameters\n        :param accountId: (Required) The account that prices are applicable for.\n        :param instruments: (Required) A (URL encoded) comma separated list of instruments to fetch prices for.\n        :param ignore_heartbeat: (optional) Whether or not to display the heartbeat. Default: True\n        ' #NEWLINE# self . connected = True #NEWLINE# request_args = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# request_args [ 'params' ] = params #NEWLINE# while self . connected : #NEWLINE# #INDENT# response = self . client . get ( self . api_url , ** request_args ) #NEWLINE# if ( response . status_code != 200 ) : #NEWLINE# #INDENT# self . on_error ( response . content ) #NEWLINE# #UNINDENT# for line in response . iter_lines ( 90 ) : #NEWLINE# #INDENT# if ( not self . connected ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# if line : #NEWLINE# #INDENT# data = json . loads ( line . decode ( 'utf-8' ) ) #NEWLINE# if ( not ( ignore_heartbeat and ( 'heartbeat' in data ) ) ) : #NEWLINE# #INDENT# self . on_success ( data )