Commit dc7ec1ff authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Renamed pending tasks join operation to wait()

parent 4b4af59b

kinetic/asyncclient.py

+1 −1
Original line number Diff line number Diff line
@@ -81,7 +81,7 @@ class AsyncClient(baseasync.BaseAsync): 
        self.queue.put((header, value, onSuccess, onError))

        eventlet.sleep(0)



    def flush(self):

    def wait(self):

        self.queue.join()



    def send(self, header, value):