METHOD_0 ( ) { alluxio . grpc . IDENT_0 [ ] IDENT_1 = java . util . stream . IDENT_2 . METHOD_1 ( ( ) -> alluxio . grpc . IDENT_0 . METHOD_2 ( ) . build ( ) ) . METHOD_3 ( ( ( alluxio . client . block . stream . IDENT_3 . IDENT_4 ) * 2 ) ) . toArray ( alluxio . grpc . IDENT_0 [ ] :: new ) ; alluxio . client . block . stream . IDENT_3 . IDENT_5 . METHOD_4 ( ( ) -> { for ( alluxio . grpc . IDENT_0 response : IDENT_1 ) { IDENT_6 . METHOD_5 ( response ) ; } try { java . lang . Thread . sleep ( alluxio . client . block . stream . IDENT_3 . IDENT_7 ) ; } catch ( e ) { java . lang . Thread . METHOD_6 ( ) . METHOD_7 ( ) ; } IDENT_6 . METHOD_8 ( ) ; } ) ; alluxio . grpc . IDENT_0 IDENT_8 = IDENT_9 . METHOD_9 ( alluxio . client . block . stream . IDENT_3 . IDENT_10 ) ; "<AssertPlaceHolder>" ; IDENT_11 . expect ( alluxio . exception . status . IDENT_12 . class ) ; IDENT_11 . METHOD_10 ( org . hamcrest . Matchers . METHOD_11 ( alluxio . client . block . stream . IDENT_3 . IDENT_13 ) ) ; IDENT_9 . METHOD_12 ( alluxio . client . block . stream . IDENT_3 . IDENT_10 ) ; } METHOD_9 ( long ) { if ( IDENT_14 ) { return null ; } if ( IDENT_15 ) { throw new alluxio . exception . status . METHOD_13 ( METHOD_14 ( STRING_0 ) ) ; } try { java . lang . Object response = IDENT_16 . METHOD_15 ( IDENT_17 , TimeUnit . IDENT_18 ) ; if ( response == null ) { throw new alluxio . exception . status . METHOD_16 ( METHOD_14 ( STRING_1 , IDENT_17 ) ) ; } if ( response == ( IDENT_6 ) ) { IDENT_14 = true ; return null ; } METHOD_17 ( ) ; return ( ( IDENT_19 ) ( response ) ) ; } catch ( java . lang . IDENT_20 e ) { java . lang . Thread . METHOD_6 ( ) . METHOD_7 ( ) ; throw new alluxio . exception . status . METHOD_13 ( METHOD_14 ( STRING_2 ) , e ) ; } }
org . junit . Assert . assertEquals ( IDENT_1 [ 0 ] , IDENT_8 )