def METHOD_NAME(
    self, channel, topic, object_stream_cb: Callable, object_cb: Callable, *args, **kwargs
):
    handler = ObjectHandler(object_stream_cb, object_cb, self.obj_tasks)
    self.blob_streamer.register_blob_callback(channel, topic, handler.handle_object, *args, **kwargs)