class_docstr: A decorator that:
      * wrap batch function
      * implement CORK algorithm to cork & release calling of wrapped function
  The wrapped function should be an async function.
class_docstr_tok: ["A","decorator","that",":","*","wrap","batch","function","*","implement","CORK","algorithm","to","cork","&","release","calling","of","wrapped","function","The","wrapped","function","should","be","an","async","function","."]
code: def _wake_event(self):
      return asyncio.Condition()
  
imports: from __future__ import annotations
  import asyncio
  import collections
  import functools
  import logging
  import time
  import traceback
  import typing
  from functools import cached_property
  import attr
  import numpy
  from ..utils.alg import TokenBucket
label_desc: Use image node_id 4 for calling the CorkDispatcher obj's underlying member method code with example usage: obj._wake_event() and returns: asyncio