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