METHOD_0 ( ) { alluxio . grpc . IDENT_0 response = alluxio . grpc . IDENT_0 . METHOD_1 ( ) . build ( ) ; alluxio . client . block . stream . IDENT_1 . IDENT_2 . METHOD_2 ( ( ) -> { try { java . lang . Thread . sleep ( alluxio . client . block . stream . IDENT_1 . IDENT_3 ) ; IDENT_4 . METHOD_3 ( response ) ; } catch ( e ) { java . lang . Thread . METHOD_4 ( ) . METHOD_5 ( ) ; } } ) ; alluxio . grpc . IDENT_0 IDENT_5 = IDENT_6 . METHOD_6 ( alluxio . client . block . stream . IDENT_1 . IDENT_7 ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( long ) { if ( IDENT_8 ) { return null ; } if ( IDENT_9 ) { throw new alluxio . exception . status . METHOD_7 ( METHOD_8 ( STRING_0 ) ) ; } try { java . lang . Object response = IDENT_10 . METHOD_9 ( IDENT_11 , TimeUnit . IDENT_12 ) ; if ( response == null ) { throw new alluxio . exception . status . METHOD_10 ( METHOD_8 ( STRING_1 , IDENT_11 ) ) ; } if ( response == ( IDENT_4 ) ) { IDENT_8 = true ; return null ; } METHOD_11 ( ) ; return ( ( IDENT_13 ) ( response ) ) ; } catch ( java . lang . IDENT_14 e ) { java . lang . Thread . METHOD_4 ( ) . METHOD_5 ( ) ; throw new alluxio . exception . status . METHOD_7 ( METHOD_8 ( STRING_2 ) , e ) ; } }
org . junit . Assert . assertEquals ( response , IDENT_5 )