servicetalk-concurrent-test-internal/src/main/java/io/servicetalk/concurrent/test/internal/AwaitUtils.java
/**
     * {@link BlockingQueue#take()} from the queue while suppressing {@link InterruptedException}s.
     * @param queue The queue to take from.
     * @param <T> The types of objects in the queue.
     * @return see {@link BlockingQueue#take()}.
     * @deprecated use {@link #take(BlockingQueue)} instead.
     */
BlockingQueue#take() from the queue while suppressing  InterruptedExceptions.
@param queue The queue to take from.
@param  The types of objects in the queue.
BlockingQueue#take () from the queue while suppressing InterruptedExceptions . @param queue The queue to take from . @param The types of objects in the queue .
@Deprecated
    public static <T> T takeUninterruptibly(BlockingQueue<T> queue) {
        boolean interrupted = false;
        try {
            do {
                try {
                    return queue.take();
                } catch (InterruptedException e) {
                    interrupted = true;
                }
            } while (true);
        } finally {
            if (interrupted) {
                Thread.currentThread().interrupt();
            }
        }
    }
@ Deprecated public static < T > T takeUninterruptibly ( BlockingQueue < T > queue ) { boolean interrupted = false ; try { do { try { return queue . take ( ) ; } catch ( InterruptedException e ) { interrupted = true ; } } while ( true ) ; } finally { if ( interrupted ) { Thread . currentThread ( ) . interrupt ( ) ; } } }
{@link BlockingQueue#take()} from the queue while suppressing {@link InterruptedException}s.
 @param queue The queue to take from.
{ @link BlockingQueue#take () } from the queue while suppressing { @link InterruptedException } s . @param queue The queue to take from .