METHOD_0 ( ) { final java . lang . String IDENT_0 = STRING_0 ; final java . lang . String IDENT_1 = STRING_1 ; org . apache . beam . runners . core . metrics . IDENT_2 IDENT_3 = new org . apache . beam . runners . core . metrics . METHOD_1 ( ) ; org . apache . beam . IDENT_4 . IDENT_5 . data . IDENT_6 IDENT_7 = new org . apache . beam . IDENT_4 . IDENT_5 . data . METHOD_2 ( IDENT_3 , mock ( org . apache . beam . runners . core . metrics . IDENT_8 . class ) ) ; org . apache . beam . sdk . IDENT_4 . data . IDENT_9 < org . apache . beam . sdk . util . IDENT_10 < java . lang . String > > IDENT_11 = mock ( org . apache . beam . sdk . IDENT_4 . data . IDENT_9 . class ) ; org . apache . beam . sdk . IDENT_4 . data . IDENT_9 < org . apache . beam . sdk . util . IDENT_10 < java . lang . String > > IDENT_12 = mock ( org . apache . beam . sdk . IDENT_4 . data . IDENT_9 . class ) ; IDENT_7 . METHOD_3 ( IDENT_0 , IDENT_1 , IDENT_11 ) ; IDENT_7 . METHOD_3 ( IDENT_0 , IDENT_1 , IDENT_12 ) ; org . apache . beam . sdk . IDENT_4 . data . IDENT_9 < org . apache . beam . sdk . util . IDENT_10 < java . lang . String > > IDENT_13 = ( ( org . apache . beam . sdk . IDENT_4 . data . IDENT_9 < org . apache . beam . sdk . util . IDENT_10 < java . lang . String > > ) ( ( org . apache . beam . sdk . IDENT_4 . data . IDENT_9 ) ( IDENT_7 . METHOD_4 ( IDENT_0 ) ) ) ) ; org . apache . beam . sdk . util . IDENT_10 < java . lang . String > element = org . apache . beam . sdk . util . IDENT_10 . METHOD_5 ( STRING_2 ) ; int IDENT_14 = 20 ; for ( int i = 0 ; i < IDENT_14 ; i ++ ) { IDENT_13 . accept ( element ) ; } verify ( IDENT_11 , times ( IDENT_14 ) ) . accept ( element ) ; verify ( IDENT_12 , times ( IDENT_14 ) ) . accept ( element ) ; "<AssertPlaceHolder>" ; } METHOD_6 ( ) { return IDENT_15 . METHOD_6 ( ) ; }
org . junit . Assert . assertThat ( IDENT_7 . METHOD_6 ( ) , org . hamcrest . Matchers . contains ( IDENT_0 ) )