'Prepare fanout context, one topic per object type.'

def _prepare_object_fanout_context(self, obj, resource_version, rpc_version):

    obj_topic = resource_type_versioned_topic(obj.obj_name(), resource_version)
    return self.client.prepare(fanout=True, topic=obj_topic, version=rpc_version)
