METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( ) ; org . hamcrest . IDENT_2 < java . lang . Integer > matcher = new org . hamcrest . IDENT_3 < java . lang . Integer > ( ) { @ org . apache . beam . sdk . testing . Override public void METHOD_2 ( org . hamcrest . IDENT_4 description ) { } @ org . apache . beam . sdk . testing . Override MOD_0 boolean METHOD_3 ( java . lang . Integer item ) { IDENT_1 . set ( true ) ; return item == INT_0 ; } } ; org . apache . beam . sdk . testing . IDENT_5 . METHOD_4 ( org . apache . beam . sdk . IDENT_6 . IDENT_7 . METHOD_5 ( ) , java . util . Arrays . asList ( 1 , 1 , 2 , 2 , 3 , 3 , 4 , 4 , 5 , 5 ) , matcher ) ; "<AssertPlaceHolder>" ; try { org . apache . beam . sdk . testing . IDENT_5 . METHOD_4 ( org . apache . beam . sdk . IDENT_6 . IDENT_7 . METHOD_5 ( ) , java . util . Arrays . asList ( 1 , 2 , 3 , 4 , 5 ) , org . hamcrest . Matchers . METHOD_6 ( org . hamcrest . Matchers . equalTo ( 15 ) ) ) ; } catch ( java . lang . IDENT_8 IDENT_9 ) { return ; } org . junit . Assert . fail ( STRING_0 ) ; } get ( ) { org . apache . beam . runners . core . IDENT_10 . IDENT_11 . IDENT_12 . IDENT_13 IDENT_14 = new org . apache . beam . runners . core . IDENT_10 . IDENT_11 . IDENT_12 . METHOD_7 ( ) ; org . apache . beam . IDENT_15 . grpc . IDENT_16 . io . grpc . IDENT_17 . IDENT_18 < org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_21 > IDENT_22 = IDENT_17 . METHOD_8 ( IDENT_14 ) ; org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_23 metadata = org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_23 . METHOD_9 ( ) . setName ( file . METHOD_10 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_24 IDENT_25 = org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_24 . METHOD_9 ( ) . METHOD_11 ( metadata ) . METHOD_12 ( IDENT_26 ) . build ( ) ; IDENT_22 . METHOD_13 ( org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_21 . METHOD_9 ( ) . METHOD_11 ( IDENT_25 ) . build ( ) ) ; org . apache . beam . IDENT_15 . IDENT_27 . IDENT_28 . com . google . common . hash . IDENT_29 IDENT_30 = org . apache . beam . IDENT_15 . IDENT_27 . IDENT_28 . com . google . common . hash . IDENT_31 . METHOD_14 ( ) . METHOD_15 ( ) ; java . nio . IDENT_32 . IDENT_33 channel = new java . io . METHOD_16 ( file . METHOD_17 ( ) ) . METHOD_18 ( ) ; java . nio . ByteBuffer IDENT_34 = java . nio . ByteBuffer . METHOD_19 ( IDENT_35 ) ; while ( ( ! ( IDENT_14 . METHOD_20 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_34 . METHOD_21 ( ) ; channel . read ( IDENT_34 ) ; IDENT_34 . METHOD_22 ( ) ; org . apache . beam . IDENT_15 . grpc . IDENT_16 . com . google . IDENT_36 . IDENT_37 IDENT_38 = org . apache . beam . IDENT_15 . grpc . IDENT_16 . com . google . IDENT_36 . IDENT_37 . METHOD_23 ( IDENT_34 ) ; IDENT_30 . METHOD_24 ( IDENT_38 . toByteArray ( ) ) ; IDENT_34 . METHOD_25 ( ) ; org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_21 request = org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_21 . METHOD_9 ( ) . METHOD_26 ( org . apache . beam . model . IDENT_19 . v1 . IDENT_20 . IDENT_39 . METHOD_9 ( ) . METHOD_26 ( IDENT_38 ) . build ( ) ) . build ( ) ; IDENT_22 . METHOD_13 ( request ) ; } IDENT_22 . METHOD_27 ( ) ; IDENT_14 . METHOD_28 ( ) ; if ( ( IDENT_14 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_14 . err . get ( ) ) ; } return metadata . METHOD_29 ( ) . METHOD_30 ( IDENT_30 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertThat ( IDENT_1 . get ( ) , org . hamcrest . Matchers . is ( true ) )