METHOD_0 ( ) { java . io . File file = java . io . File . METHOD_1 ( "test" , STRING_0 ) ; alluxio . grpc . IDENT_0 response = alluxio . grpc . IDENT_0 . METHOD_2 ( ) . METHOD_3 ( file . getAbsolutePath ( ) ) . build ( ) ; when ( IDENT_1 . METHOD_4 ( any ( io . grpc . IDENT_2 . IDENT_3 . class ) ) ) . METHOD_5 ( new org . mockito . IDENT_4 . METHOD_6 ( ) { public java . lang . Object METHOD_7 ( org . mockito . IDENT_5 . IDENT_6 IDENT_5 ) { io . grpc . IDENT_2 . IDENT_3 < alluxio . grpc . IDENT_0 > IDENT_7 = IDENT_5 . METHOD_8 ( 0 , io . grpc . IDENT_2 . IDENT_3 . class ) ; IDENT_7 . METHOD_9 ( response ) ; return IDENT_8 ; } } ) ; when ( IDENT_9 . METHOD_10 ( ) ) . thenReturn ( com . google . common . collect . Lists . newArrayList ( new alluxio . IDENT_10 . METHOD_11 ( ) . METHOD_12 ( alluxio . client . block . IDENT_11 . IDENT_12 ) , new alluxio . IDENT_10 . METHOD_11 ( ) . METHOD_12 ( alluxio . client . block . IDENT_11 . IDENT_13 ) ) ) ; alluxio . client . file . options . IDENT_14 options = alluxio . client . file . options . IDENT_14 . METHOD_13 ( alluxio . client . block . IDENT_11 . IDENT_15 ) . METHOD_14 ( alluxio . client . block . IDENT_11 . IDENT_16 ) . METHOD_15 ( new alluxio . client . block . IDENT_11 . METHOD_16 ( com . google . common . collect . Lists . newArrayList ( alluxio . client . block . IDENT_11 . IDENT_12 , alluxio . client . block . IDENT_11 . IDENT_13 ) ) ) . METHOD_17 ( IDENT_17 . IDENT_18 ) . METHOD_18 ( 2 ) ; alluxio . client . block . stream . IDENT_19 stream = IDENT_20 . METHOD_19 ( alluxio . client . block . IDENT_11 . IDENT_21 , alluxio . client . block . IDENT_11 . IDENT_16 , options ) ; "<AssertPlaceHolder>" ; } METHOD_19 ( long , long , alluxio . client . file . options . IDENT_14 ) { alluxio . IDENT_10 . IDENT_22 address ; alluxio . client . block . policy . IDENT_23 IDENT_24 = com . google . common . base . IDENT_25 . METHOD_20 ( options . METHOD_21 ( ) , IDENT_26 . IDENT_27 ) ; alluxio . client . block . policy . options . IDENT_28 IDENT_29 = alluxio . client . block . policy . options . IDENT_28 . METHOD_13 ( ) . METHOD_22 ( new alluxio . IDENT_10 . METHOD_23 ( ) . METHOD_24 ( IDENT_30 ) . METHOD_25 ( IDENT_31 ) ) . METHOD_26 ( new java . util . ArrayList ( METHOD_27 ( ) ) ) ; int IDENT_32 = ( ( ( options . METHOD_28 ( ) ) == ( alluxio . client . IDENT_17 . IDENT_33 ) ) && ( ( options . METHOD_29 ( ) ) > ( options . METHOD_30 ( ) ) ) ) ? options . METHOD_29 ( ) : options . METHOD_30 ( ) ; if ( IDENT_32 <= 1 ) { address = IDENT_24 . METHOD_31 ( IDENT_29 ) ; if ( address == null ) { throw new alluxio . exception . status . METHOD_32 ( IDENT_34 . IDENT_35 . getMessage ( IDENT_31 ) ) ; } return METHOD_19 ( IDENT_30 , IDENT_31 , address , options ) ; } java . util . Map < java . lang . String , java . util . Set < alluxio . client . block . IDENT_36 > > IDENT_37 = new java . util . HashMap ( ) ; for ( alluxio . client . block . IDENT_36 IDENT_38 : IDENT_29 . METHOD_33 ( ) ) { java . lang . String IDENT_39 = IDENT_38 . METHOD_34 ( ) . METHOD_35 ( ) ; if ( IDENT_37 . containsKey ( IDENT_39 ) ) { IDENT_37 . get ( IDENT_39 ) . add ( IDENT_38 ) ; } else { IDENT_37 . put ( IDENT_39 , com . google . common . collect . IDENT_40 . METHOD_36 ( IDENT_38 ) ) ; } } java . util . List < alluxio . IDENT_10 . IDENT_22 > IDENT_41 = new java . util . ArrayList ( ) ; java . util . List < alluxio . client . block . IDENT_36 > IDENT_42 = com . google . common . collect . Lists . newArrayList ( IDENT_29 . METHOD_33 ( ) ) ; for ( int i = 0 ; i < IDENT_32 ; i ++ ) { address = IDENT_24 . METHOD_31 ( IDENT_29 ) ; if ( address == null ) { break ; } IDENT_41 . add ( address ) ; IDENT_42 . METHOD_37 ( IDENT_37 . get ( address . METHOD_35 ( ) ) ) ; IDENT_29 . METHOD_26 ( IDENT_42 ) ; } if ( ( IDENT_41 . size ( ) ) < IDENT_32 ) { throw new alluxio . exception . status . METHOD_38 ( java . lang . String . format ( STRING_1 , IDENT_41 . size ( ) , IDENT_32 ) ) ; } return alluxio . client . block . stream . IDENT_19 . METHOD_39 ( IDENT_43 , IDENT_30 , IDENT_31 , IDENT_41 , options ) ; }
org . junit . Assert . assertEquals ( alluxio . client . block . stream . IDENT_19 . class , stream . getClass ( ) )