METHOD_0 ( ) { Map . Entry < org . apache . IDENT_0 . IDENT_1 . IDENT_2 , org . apache . IDENT_0 . IDENT_1 . IDENT_3 > entry = create ( ) ; try { final org . apache . IDENT_0 . IDENT_1 . IDENT_2 service = entry . getKey ( ) ; org . apache . IDENT_0 . IDENT_1 . IDENT_3 client = entry . getValue ( ) ; final java . lang . String IDENT_4 = STRING_0 ; org . apache . IDENT_0 . IDENT_1 . IDENT_5 IDENT_6 = client . METHOD_1 ( IDENT_4 ) ; java . lang . Thread t = new java . lang . Thread ( ) { @ org . apache . IDENT_0 . IDENT_1 . Override public void run ( ) { service . METHOD_2 ( new org . apache . IDENT_0 . IDENT_1 . METHOD_3 ( IDENT_4 , new java . net . METHOD_4 ( INT_0 ) , new byte [ ] { } ) ) ; } } ; java . util . Iterator < org . apache . IDENT_0 . IDENT_1 . METHOD_3 > iterator = IDENT_6 . iterator ( ) ; t . start ( ) ; t . join ( ) ; "<AssertPlaceHolder>" ; } finally { METHOD_5 ( entry ) ; } } start ( ) { java . util . concurrent . IDENT_7 IDENT_8 = java . util . concurrent . IDENT_9 . METHOD_6 ( org . apache . IDENT_0 . common . IDENT_10 . METHOD_7 ( STRING_1 ) ) ; final org . apache . IDENT_0 . internal . kafka . client . IDENT_11 . IDENT_12 listener = new org . apache . IDENT_0 . internal . kafka . client . IDENT_11 . METHOD_8 ( IDENT_13 , IDENT_14 , IDENT_15 , IDENT_16 ) ; org . apache . IDENT_0 . common . IDENT_17 IDENT_18 = IDENT_19 . METHOD_9 ( listener , IDENT_8 ) ; java . util . concurrent . IDENT_20 < ? > IDENT_21 = IDENT_8 . METHOD_10 ( new java . lang . METHOD_11 ( ) { @ org . apache . IDENT_0 . internal . kafka . client . Override public void run ( ) { listener . METHOD_12 ( IDENT_19 ) ; } } ) ; com . google . common . util . concurrent . IDENT_22 . METHOD_13 ( IDENT_21 ) ; return new org . apache . IDENT_0 . internal . kafka . client . IDENT_11 . METHOD_14 ( IDENT_8 , IDENT_13 , IDENT_18 , IDENT_14 ) ; }
org . junit . Assert . assertFalse ( iterator . hasNext ( ) )