def METHOD_NAME(self, future: StreamFuture, obj_sid: int, index: int, *args, **kwargs):
    blob = future.result()
    self.object_cb(obj_sid, index, Message(future.get_headers(), blob), *args, **kwargs)