@Test
void shouldHandleInterruptsInBlockingGet()
{

    try
    {
        CompletableFuture<String> future = new CompletableFuture<>();
        Thread.currentThread().interrupt();
        Runnable interruptHandler = () -> future.complete( "Hello" );
        assertEquals( "Hello", Futures.blockingGet( future, interruptHandler ) );
        assertTrue( Thread.currentThread().isInterrupted() );
    }
    finally
    {
        Thread.interrupted(); // clear interruption status
    }
}