METHOD_0 ( ) { java . lang . RuntimeException IDENT_0 = new java . lang . RuntimeException ( ) ; java . util . concurrent . atomic . IDENT_1 IDENT_2 = new java . util . concurrent . atomic . METHOD_1 ( ) ; org . apache . beam . runners . IDENT_3 . IDENT_4 . test . IDENT_5 . METHOD_2 ( null ) . METHOD_3 ( ( ) -> IDENT_2 . set ( true ) ) . build ( ) . METHOD_4 ( IDENT_0 ) ; "<AssertPlaceHolder>" ; } get ( ) { org . apache . beam . runners . core . IDENT_6 . IDENT_7 . IDENT_8 . IDENT_9 IDENT_10 = new org . apache . beam . runners . core . IDENT_6 . IDENT_7 . IDENT_8 . METHOD_5 ( ) ; org . apache . beam . IDENT_11 . grpc . IDENT_12 . io . grpc . IDENT_13 . IDENT_14 < org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 > IDENT_18 = IDENT_13 . METHOD_6 ( IDENT_10 ) ; org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_19 metadata = org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_19 . METHOD_7 ( ) . setName ( file . METHOD_8 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_20 IDENT_21 = org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_20 . METHOD_7 ( ) . METHOD_9 ( metadata ) . METHOD_10 ( IDENT_22 ) . build ( ) ; IDENT_18 . METHOD_11 ( org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 . METHOD_7 ( ) . METHOD_9 ( IDENT_21 ) . build ( ) ) ; org . apache . beam . IDENT_11 . IDENT_23 . IDENT_24 . com . google . common . hash . IDENT_25 IDENT_26 = org . apache . beam . IDENT_11 . IDENT_23 . IDENT_24 . com . google . common . hash . IDENT_27 . METHOD_12 ( ) . METHOD_13 ( ) ; java . nio . IDENT_28 . IDENT_29 channel = new java . io . METHOD_14 ( file . METHOD_15 ( ) ) . METHOD_16 ( ) ; java . nio . ByteBuffer IDENT_30 = java . nio . ByteBuffer . METHOD_17 ( IDENT_31 ) ; while ( ( ! ( IDENT_10 . METHOD_18 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_30 . METHOD_19 ( ) ; channel . read ( IDENT_30 ) ; IDENT_30 . METHOD_20 ( ) ; org . apache . beam . IDENT_11 . grpc . IDENT_12 . com . google . IDENT_32 . IDENT_33 IDENT_34 = org . apache . beam . IDENT_11 . grpc . IDENT_12 . com . google . IDENT_32 . IDENT_33 . METHOD_21 ( IDENT_30 ) ; IDENT_26 . METHOD_22 ( IDENT_34 . toByteArray ( ) ) ; IDENT_30 . METHOD_23 ( ) ; org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 request = org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 . METHOD_7 ( ) . METHOD_24 ( org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_35 . METHOD_7 ( ) . METHOD_24 ( IDENT_34 ) . build ( ) ) . build ( ) ; IDENT_18 . METHOD_11 ( request ) ; } IDENT_18 . METHOD_25 ( ) ; IDENT_10 . METHOD_26 ( ) ; if ( ( IDENT_10 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_10 . err . get ( ) ) ; } return metadata . METHOD_27 ( ) . METHOD_28 ( IDENT_26 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertTrue ( IDENT_2 . get ( ) )