#NEWLINE# @ defer . inlineCallbacks #NEWLINE# def current_replication_token( self ) : #NEWLINE# #INDENT# stream_token = ( yield self . sources . get_current_token ( ) ) #NEWLINE# backfill_token = ( yield self . store . get_current_backfill_token ( ) ) #NEWLINE# ( push_rules_token , room_stream_token ) = self . store . get_push_rules_stream_token ( ) #NEWLINE# pushers_token = self . store . get_pushers_stream_token ( ) #NEWLINE# defer . returnValue ( _ReplicationToken ( room_stream_token , int ( stream_token . presence_key ) , int ( backfill_token . typing_key ) , int ( stream_token . receipt_key ) , int ( stream_token . account_data_key ) , backfill_token , push_rules_token , pushers_token ) )