METHOD_0 ( ) { org . IDENT_0 . IDENT_1 . IDENT_2 IDENT_3 = new org . IDENT_0 . IDENT_1 . METHOD_1 ( ) ; IDENT_3 . start ( ) ; org . IDENT_0 . IDENT_4 . IDENT_5 < java . lang . String > channel = new org . IDENT_0 . IDENT_4 . IDENT_5 < java . lang . String > ( ) ; final int max = INT_0 ; final org . IDENT_0 . IDENT_4 . IDENT_6 IDENT_7 = new org . IDENT_0 . IDENT_4 . METHOD_2 ( 1 ) ; org . IDENT_0 . IDENT_4 . IDENT_8 < org . IDENT_0 . IDENT_4 . IDENT_9 < java . lang . String > > cb = new org . IDENT_0 . IDENT_4 . IDENT_8 < org . IDENT_0 . IDENT_4 . IDENT_9 < java . lang . String > > ( ) { int IDENT_10 = 0 ; public void METHOD_3 ( org . IDENT_0 . IDENT_4 . IDENT_9 < java . lang . String > batch ) { IDENT_10 += batch . size ( ) ; if ( ( IDENT_10 ) == max ) { IDENT_7 . METHOD_4 ( ) ; } } } ; org . IDENT_0 . IDENT_4 . IDENT_11 < java . lang . String > batch = new org . IDENT_0 . IDENT_4 . IDENT_11 < java . lang . String > ( IDENT_3 , cb , 0 , TimeUnit . IDENT_12 ) ; channel . METHOD_5 ( batch ) ; org . IDENT_0 . IDENT_13 IDENT_14 = new org . IDENT_0 . METHOD_6 ( max ) ; try { for ( int i = 0 ; i < max ; i ++ ) { channel . METHOD_7 ( STRING_0 ) ; } boolean result = IDENT_7 . METHOD_8 ( INT_1 , TimeUnit . IDENT_15 ) ; "<AssertPlaceHolder>" ; } finally { IDENT_14 . METHOD_9 ( ) ; IDENT_3 . METHOD_9 ( ) ; } } METHOD_7 ( T ) { org . IDENT_0 . IDENT_4 . IDENT_16 . METHOD_10 ( msg , IDENT_17 ) ; }
org . junit . Assert . assertTrue ( result )