METHOD_0 ( ) { org . apache . beam . sdk . IDENT_0 p = org . apache . beam . sdk . IDENT_0 . create ( options ) ; org . apache . beam . sdk . values . IDENT_1 < java . lang . Integer > IDENT_2 = p . apply ( org . apache . beam . sdk . IDENT_3 . IDENT_4 . of ( 1 , 2 , 3 ) ) ; org . apache . beam . sdk . testing . IDENT_5 . that ( IDENT_2 ) . METHOD_1 ( 1 , 2 , 3 ) ; org . apache . beam . runners . IDENT_6 . IDENT_7 IDENT_8 = org . mockito . Mockito . mock ( org . apache . beam . runners . IDENT_6 . IDENT_7 . class ) ; when ( IDENT_8 . METHOD_2 ( ) ) . thenReturn ( IDENT_9 . IDENT_10 ) ; when ( IDENT_8 . METHOD_3 ( ) ) . thenReturn ( STRING_0 ) ; when ( IDENT_8 . METHOD_4 ( ) ) . thenReturn ( STRING_1 ) ; org . apache . beam . runners . IDENT_6 . IDENT_11 IDENT_12 = org . mockito . Mockito . mock ( org . apache . beam . runners . IDENT_6 . IDENT_11 . class ) ; when ( IDENT_12 . run ( any ( org . apache . beam . sdk . IDENT_0 . class ) ) ) . thenReturn ( IDENT_8 ) ; org . apache . beam . runners . IDENT_6 . IDENT_13 runner = org . apache . beam . runners . IDENT_6 . IDENT_13 . METHOD_5 ( options , IDENT_14 ) ; when ( IDENT_14 . METHOD_6 ( anyString ( ) ) ) . thenReturn ( METHOD_7 ( true , true ) ) ; "<AssertPlaceHolder>" ; } run ( org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 , org . apache . beam . IDENT_18 . grpc . IDENT_19 . io . grpc . IDENT_20 . IDENT_21 ) { org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_24 . LOG . trace ( STRING_2 , org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_17 . class . METHOD_8 ( ) , request ) ; java . lang . String IDENT_25 = request . METHOD_9 ( ) ; try { org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_26 IDENT_27 = IDENT_28 . get ( IDENT_25 ) ; if ( IDENT_27 == null ) { java . lang . String IDENT_29 = java . lang . String . format ( STRING_3 , IDENT_25 ) ; org . apache . beam . IDENT_18 . grpc . IDENT_19 . io . grpc . IDENT_30 exception = Status . IDENT_31 . METHOD_10 ( IDENT_29 ) . METHOD_11 ( ) ; IDENT_32 . METHOD_12 ( exception ) ; return ; } try { org . apache . beam . runners . core . IDENT_33 . graph . IDENT_34 . validate ( IDENT_27 . pipeline ( ) ) ; } catch ( java . lang . Exception e ) { org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_24 . LOG . warn ( STRING_4 , e ) ; IDENT_32 . METHOD_12 ( new org . apache . beam . IDENT_18 . grpc . IDENT_19 . io . grpc . METHOD_13 ( Status . IDENT_35 . METHOD_14 ( e ) ) ) ; return ; } org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_36 IDENT_37 = IDENT_38 . invoke ( IDENT_27 . pipeline ( ) , IDENT_27 . options ( ) , request . METHOD_15 ( ) ) ; java . lang . String IDENT_39 = IDENT_37 . getId ( ) ; IDENT_37 . METHOD_16 ( ( state ) -> { if ( ! ( org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_36 . METHOD_17 ( state ) ) ) { return ; } java . lang . String IDENT_40 = IDENT_41 . get ( IDENT_25 ) ; IDENT_41 . remove ( IDENT_25 ) ; if ( ( IDENT_42 ) != null ) { try { IDENT_42 . accept ( IDENT_40 ) ; } catch ( e ) { org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_24 . LOG . error ( STRING_5 , IDENT_40 , org . apache . beam . runners . IDENT_22 . IDENT_23 . e ) ; } } } ) ; IDENT_37 . start ( ) ; IDENT_43 . put ( IDENT_39 , IDENT_37 ) ; org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_44 response = org . apache . beam . model . IDENT_15 . v1 . IDENT_16 . IDENT_44 . METHOD_18 ( ) . METHOD_19 ( IDENT_39 ) . build ( ) ; IDENT_32 . METHOD_20 ( response ) ; IDENT_32 . METHOD_21 ( ) ; } catch ( org . apache . beam . IDENT_18 . grpc . IDENT_19 . io . grpc . METHOD_13 e ) { org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_24 . LOG . warn ( STRING_6 , e ) ; IDENT_32 . METHOD_12 ( e ) ; } catch ( java . lang . Exception e ) { java . lang . String IDENT_29 = java . lang . String . format ( STRING_7 , IDENT_25 ) ; org . apache . beam . runners . IDENT_22 . IDENT_23 . IDENT_24 . LOG . error ( IDENT_29 , e ) ; IDENT_32 . METHOD_12 ( Status . IDENT_45 . METHOD_14 ( e ) . METHOD_11 ( ) ) ; } }
org . junit . Assert . assertEquals ( IDENT_8 , runner . run ( p , IDENT_12 ) )