async def METHOD_NAME(self, op_id, frame):
    async with self._futures_lock:
        future = self._futures.get(op_id, None)
        if not future:
            return
        future.set_result(frame)