'Called when a new connection has been established and we need to
subscribe to streams.
Returns a dictionary of stream name to token.'

def get_streams_to_replicate(self):

    args = self.store.stream_positions()
    user_account_data = args.pop('user_account_data', None)
    room_account_data = args.pop('room_account_data', None)
    if user_account_data:
        args['account_data'] = user_account_data
    elif room_account_data:
        args['account_data'] = room_account_data
    return args
