METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( false ) ; final org . apache . rya . streams . api . entity . IDENT_2 < org . apache . rya . api . model . IDENT_3 > IDENT_4 = mock ( org . apache . rya . streams . api . entity . IDENT_2 . class ) ; when ( IDENT_4 . METHOD_2 ( METHOD_3 ( ) ) ) . METHOD_4 ( ( IDENT_5 ) -> { IDENT_1 . set ( true ) ; final List < org . apache . rya . api . model . IDENT_3 > results = new org . apache . rya . streams . client . util . ArrayList < > ( ) ; org . eclipse . IDENT_6 . model . IDENT_7 stmt = org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_5 ( org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_6 ( STRING_0 ) , org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_6 ( STRING_1 ) , org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_7 ( INT_0 ) ) ; results . add ( new org . apache . rya . api . model . METHOD_8 ( stmt ) ) ; stmt = org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_5 ( org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_6 ( STRING_2 ) , org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_6 ( STRING_3 ) , org . apache . rya . streams . client . util . IDENT_8 . IDENT_9 . METHOD_7 ( STRING_4 ) ) ; results . add ( new org . apache . rya . api . model . METHOD_8 ( stmt ) ) ; return results ; } ) ; final java . io . ByteArrayOutputStream out = new java . io . ByteArrayOutputStream ( ) ; org . apache . rya . streams . client . util . IDENT_10 . METHOD_0 ( out , IDENT_4 , IDENT_1 ) ; final java . lang . String expected = STRING_5 + STRING_6 ; final java . lang . String IDENT_11 = new java . lang . String ( out . toByteArray ( ) , com . google . common . base . IDENT_12 . UTF_8 ) ; "<AssertPlaceHolder>" ; } METHOD_0 ( java . io . IDENT_13 , org . apache . rya . streams . api . entity . IDENT_2 , java . util . concurrent . atomic . METHOD_1 ) { METHOD_9 ( out ) ; METHOD_9 ( IDENT_4 ) ; METHOD_9 ( IDENT_1 ) ; final org . eclipse . IDENT_6 . IDENT_14 . IDENT_15 writer = org . eclipse . IDENT_6 . IDENT_14 . IDENT_16 . METHOD_10 ( IDENT_17 . IDENT_18 , out ) ; writer . METHOD_11 ( ) ; while ( ! ( IDENT_1 . get ( ) ) ) { final java . lang . IDENT_19 < org . apache . rya . api . model . METHOD_8 > it = IDENT_4 . METHOD_2 ( 1000 ) ; for ( final org . apache . rya . api . model . METHOD_8 result : it ) { writer . METHOD_12 ( result ) ; } } writer . METHOD_13 ( ) ; }
org . junit . Assert . assertEquals ( expected , IDENT_11 )