@ Override public T get ( ) { try { latch . await ( ) ; return output . get ( ) ; } catch ( InterruptedException e ) { throw new RedisCommandInterruptedException ( e ) ; } }
Get the command output and if the command hasn t completed yet wait until it does .