asana_hub/transport.py
def flush(callback=None):
    """Waits until queue is empty."""

    while True:
        if shutdown_event.is_set():
            return

        if callable(callback):
            callback()

        try:
            item = queue.get(timeout=1)
            queue.put(item)  # put it back, we're just peeking.
        except Queue.Empty:
            return
def flush(callback=None):
    """Waits until queue is empty."""

    while True:
        if shutdown_event.is_set():
            return

        if callable(callback):
            callback()

        try:
            item = queue.get(timeout=1)
            queue.put(item)  # put it back, we're just peeking.
        except Queue.Empty:
            return
def flush ( callback = None ) : while True : if shutdown_event . is_set ( ) : return if callable ( callback ) : callback ( ) try : item = queue . get ( timeout = 1 ) queue . put ( item ) # put it back, we're just peeking. except Queue . Empty : return
Waits until queue is empty.
Waits until queue is empty .