#NEWLINE# @ defer . inlineCallbacks #NEWLINE# def get_current_token( self , direction = 'f' ) : #NEWLINE# #INDENT# ( push_rules_key , _ ) = self . store . get_push_rules_stream_token ( ) #NEWLINE# token = StreamToken ( room_key = ( yield self . sources [ 'room' ] . get_current_key ( direction ) ) , presence_key = ( yield self . sources [ 'presence' ] . get_current_key ( ) ) , typing_key = ( yield self . sources [ 'typing' ] . get_current_key ( ) ) , receipt_key = ( yield self . sources [ 'receipt' ] . get_current_key ( ) ) , account_data_key = ( yield self . sources [ 'account_data' ] . get_current_key ( ) ) , push_rules_key = push_rules_key ) #NEWLINE# defer . returnValue ( token )