METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; java . util . concurrent . IDENT_1 < java . lang . String > IDENT_2 = new java . util . concurrent . METHOD_1 ( ) ; java . util . function . IDENT_3 < org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_6 . IDENT_7 < org . apache . beam . model . IDENT_8 . v1 . IDENT_9 . IDENT_10 > > consumer = ( IDENT_11 ) -> IDENT_2 . METHOD_2 ( org . apache . beam . runners . IDENT_8 . IDENT_12 . METHOD_3 ( ) . METHOD_4 ( ) ) ; org . apache . beam . runners . IDENT_8 . IDENT_13 . IDENT_14 IDENT_15 = new org . apache . beam . runners . IDENT_8 . IDENT_13 . METHOD_5 ( org . mockito . Mockito . mock ( org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_6 . IDENT_7 . class ) , consumer ) ; org . apache . beam . model . pipeline . v1 . IDENT_16 . IDENT_17 IDENT_18 = org . apache . beam . model . pipeline . v1 . IDENT_16 . IDENT_17 . METHOD_6 ( ) . METHOD_7 ( STRING_1 ) . build ( ) ; org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_19 server = org . apache . beam . runners . IDENT_8 . IDENT_20 . create ( ) . create ( org . apache . beam . IDENT_4 . IDENT_21 . IDENT_22 . com . google . common . collect . ImmutableList . of ( IDENT_15 ) , IDENT_18 ) ; final org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_23 . IDENT_24 < java . lang . String > IDENT_25 = IDENT_23 . IDENT_24 . of ( STRING_2 , IDENT_23 . IDENT_26 ) ; org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_27 channel = org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_28 . IDENT_29 . METHOD_8 ( IDENT_18 . METHOD_9 ( ) ) . METHOD_10 ( new org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . METHOD_11 ( ) { @ org . apache . beam . runners . IDENT_8 . Override public < IDENT_30 , IDENT_31 > org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_32 < IDENT_30 , IDENT_31 > METHOD_12 ( org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_33 < IDENT_30 , IDENT_31 > method , org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_34 IDENT_35 , org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_27 next ) { org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_32 < IDENT_30 , IDENT_31 > call = next . METHOD_13 ( method , IDENT_35 ) ; return new org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_36 . IDENT_37 < IDENT_30 , IDENT_31 > ( call ) { @ org . apache . beam . runners . IDENT_8 . Override public void start ( org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_32 . IDENT_38 < IDENT_31 > IDENT_39 , org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_23 headers ) { headers . put ( IDENT_25 , IDENT_0 ) ; super . start ( IDENT_39 , headers ) ; } } ; } } ) . build ( ) ; org . apache . beam . model . IDENT_8 . v1 . IDENT_40 . IDENT_41 IDENT_6 = org . apache . beam . model . IDENT_8 . v1 . IDENT_40 . METHOD_14 ( channel ) ; IDENT_6 . data ( org . mockito . Mockito . mock ( org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_6 . IDENT_7 . class ) ) ; server . METHOD_15 ( ) ; "<AssertPlaceHolder>" ; } get ( ) { org . apache . beam . runners . core . IDENT_42 . IDENT_43 . IDENT_44 . IDENT_45 IDENT_46 = new org . apache . beam . runners . core . IDENT_42 . IDENT_43 . IDENT_44 . METHOD_16 ( ) ; org . apache . beam . IDENT_4 . grpc . IDENT_5 . io . grpc . IDENT_6 . IDENT_7 < org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_49 > IDENT_50 = IDENT_6 . METHOD_17 ( IDENT_46 ) ; org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_51 metadata = org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_51 . METHOD_6 ( ) . setName ( file . METHOD_18 ( ) ) . build ( ) ; org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_52 IDENT_53 = org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_52 . METHOD_6 ( ) . METHOD_19 ( metadata ) . METHOD_20 ( IDENT_54 ) . build ( ) ; IDENT_50 . METHOD_21 ( org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_49 . METHOD_6 ( ) . METHOD_19 ( IDENT_53 ) . build ( ) ) ; org . apache . beam . IDENT_4 . IDENT_21 . IDENT_22 . com . google . common . hash . IDENT_55 IDENT_56 = org . apache . beam . IDENT_4 . IDENT_21 . IDENT_22 . com . google . common . hash . IDENT_57 . METHOD_22 ( ) . METHOD_23 ( ) ; java . nio . IDENT_58 . IDENT_59 channel = new java . io . METHOD_24 ( file . METHOD_25 ( ) ) . METHOD_26 ( ) ; java . nio . ByteBuffer IDENT_60 = java . nio . ByteBuffer . METHOD_27 ( IDENT_61 ) ; while ( ( ! ( IDENT_46 . METHOD_28 ( ) ) ) && ( ( channel . position ( ) ) < ( channel . size ( ) ) ) ) { IDENT_60 . METHOD_29 ( ) ; channel . read ( IDENT_60 ) ; IDENT_60 . METHOD_30 ( ) ; org . apache . beam . IDENT_4 . grpc . IDENT_5 . com . google . IDENT_62 . IDENT_63 IDENT_64 = org . apache . beam . IDENT_4 . grpc . IDENT_5 . com . google . IDENT_62 . IDENT_63 . METHOD_31 ( IDENT_60 ) ; IDENT_56 . METHOD_32 ( IDENT_64 . toByteArray ( ) ) ; IDENT_60 . METHOD_33 ( ) ; org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_49 request = org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_49 . METHOD_6 ( ) . METHOD_34 ( org . apache . beam . model . IDENT_47 . v1 . IDENT_48 . IDENT_65 . METHOD_6 ( ) . METHOD_34 ( IDENT_64 ) . build ( ) ) . build ( ) ; IDENT_50 . METHOD_21 ( request ) ; } IDENT_50 . METHOD_35 ( ) ; IDENT_46 . METHOD_36 ( ) ; if ( ( IDENT_46 . err . get ( ) ) != null ) { throw new java . lang . RuntimeException ( IDENT_46 . err . get ( ) ) ; } return metadata . METHOD_37 ( ) . METHOD_38 ( IDENT_56 . hash ( ) . toString ( ) ) . build ( ) ; }
org . junit . Assert . assertEquals ( IDENT_0 , IDENT_2 . get ( ) )