METHOD_0 ( ) { final com . amazonaws . services . IDENT_0 . IDENT_1 client = IDENT_2 . METHOD_1 ( ) ; final java . lang . String IDENT_3 = IDENT_2 . METHOD_2 ( ) ; java . util . List < com . amazonaws . services . IDENT_0 . model . IDENT_4 > messages = new java . util . ArrayList ( ) ; for ( int i = 0 ; i < 100 ; i ++ ) { final com . amazonaws . services . IDENT_0 . model . IDENT_4 request = new com . amazonaws . services . IDENT_0 . model . METHOD_3 ( IDENT_3 , ( STRING_0 + i ) ) ; messages . add ( request ) ; } pipeline . apply ( org . apache . beam . sdk . IDENT_5 . IDENT_6 . of ( messages ) ) . apply ( org . apache . beam . sdk . io . IDENT_7 . IDENT_0 . IDENT_8 . write ( ) ) ; pipeline . run ( ) . METHOD_4 ( ) ; java . util . List < java . lang . String > IDENT_9 = new java . util . ArrayList ( ) ; while ( ( IDENT_9 . size ( ) ) < 100 ) { final com . amazonaws . services . IDENT_0 . model . IDENT_10 IDENT_11 = client . METHOD_5 ( IDENT_3 ) ; if ( ( IDENT_11 . METHOD_6 ( ) ) != null ) { for ( com . amazonaws . services . IDENT_0 . model . Message message : IDENT_11 . METHOD_6 ( ) ) { IDENT_9 . add ( message . METHOD_7 ( ) ) ; } } } "<AssertPlaceHolder>" ; for ( int i = 0 ; i < 100 ; i ++ ) { IDENT_9 . contains ( ( STRING_0 + i ) ) ; } } size ( ) { return size ; }
org . junit . Assert . assertEquals ( 100 , IDENT_9 . size ( ) )