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