METHOD_0 ( ) { final org . apache . beam . sdk . IDENT_0 . stream . IDENT_1 . IDENT_2 < java . lang . String > iterator = new org . apache . beam . sdk . IDENT_0 . stream . IDENT_1 . METHOD_1 ( new java . util . concurrent . IDENT_3 < java . lang . String > ( ) ) ; final org . apache . beam . IDENT_4 . IDENT_5 . IDENT_6 . com . google . common . util . concurrent . IDENT_7 < java . util . List < java . lang . String > > IDENT_8 = org . apache . beam . IDENT_4 . IDENT_5 . IDENT_6 . com . google . common . util . concurrent . IDENT_7 . create ( ) ; java . lang . Thread IDENT_9 = new java . lang . Thread ( ( ) -> IDENT_8 . set ( java . util . Arrays . asList ( org . apache . beam . IDENT_4 . IDENT_5 . IDENT_6 . com . google . common . collect . IDENT_10 . toArray ( iterator , . class ) ) ) ) ; IDENT_9 . start ( ) ; iterator . accept ( STRING_0 ) ; iterator . accept ( STRING_1 ) ; iterator . close ( ) ; "<AssertPlaceHolder>" ; IDENT_9 . join ( ) ; } asList ( java . util . Iterator , int ) { java . util . List < T > list = new java . util . ArrayList ( ) ; for ( int i = 0 ; ( i < IDENT_11 ) && ( IDENT_12 . hasNext ( ) ) ; i ++ ) { list . add ( IDENT_12 . next ( ) ) ; } return list ; }
org . junit . Assert . assertEquals ( java . util . Arrays . asList ( STRING_0 , STRING_1 ) , IDENT_8 . get ( ) )