

def _connectSchedule(self, f, meth, *args, **kwargs):
    qop = Deferred()
    qop.addCallback((lambda x: f(meth, *args, **kwargs)))
    self._evq['connect'].schedule(qop)
    return qop

dataset/ETHPy150Open couchbase/couchbase-python-client/txcouchbase/bucket.py Bucket._connectSchedule/original