def add_async(self, queue_name=_DEFAULT_QUEUE, transactional=False, rpc=None):
    return Queue(queue_name).add_async(self, transactional, rpc)
Proxy C{dataReceived} calls to our C{self._wrappedProtocol}
dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/api/taskqueue/taskqueue.py/Task.add_async--crossover with--dataset/ETHPy150Open nlloyd/SubliminalCollaborator/libs/twisted/internet/endpoints.py/_WrappingProtocol.dataReceived