METHOD_0 ( ) { METHOD_1 ( ) ; final org . apache . kafka . common . IDENT_0 IDENT_1 = new org . apache . kafka . common . METHOD_2 ( IDENT_2 , 0 ) ; consumer . METHOD_3 ( com . google . common . collect . Lists . newArrayList ( IDENT_1 ) ) ; consumer . METHOD_4 ( com . google . common . collect . Lists . newArrayList ( IDENT_1 ) ) ; final org . eclipse . IDENT_3 . common . IDENT_4 . IDENT_5 < org . apache . rya . streams . api . IDENT_6 . IDENT_7 < org . apache . rya . streams . api . IDENT_6 . IDENT_8 > , org . apache . rya . streams . api . IDENT_6 . IDENT_9 . IDENT_10 > IDENT_11 = IDENT_12 . METHOD_5 ( INT_0 ) ; int count = 0 ; while ( IDENT_11 . hasNext ( ) ) { IDENT_11 . next ( ) ; count ++ ; } "<AssertPlaceHolder>" ; } next ( ) { if ( ! ( METHOD_6 ( ) ) ) { METHOD_7 ( ) ; } if ( METHOD_6 ( ) ) { final org . eclipse . IDENT_3 . query . IDENT_13 IDENT_14 = IDENT_15 . next ( ) ; return new IDENT_16 . IDENT_17 < org . apache . rya . api . domain . IDENT_18 , org . eclipse . IDENT_3 . query . IDENT_13 > ( IDENT_19 , IDENT_14 ) ; } return null ; }
org . junit . Assert . assertEquals ( 0 , count )