#NEWLINE# @ ds . on_open #NEWLINE# def on_open( ) : #NEWLINE# #INDENT# print ( 'Streaming ready, can start subscribing' ) #NEWLINE# csdl = 'interaction.content contains "music"' #NEWLINE# stream = ds . compile ( subscribe_to_hash ) [ 'hash' ] #NEWLINE# @ ds . subscribe ( stream ) #NEWLINE# def subscribe_to_hash( msg ) : #NEWLINE# #INDENT# print ( msg )