METHOD_0 ( ) { final java . util . concurrent . IDENT_0 < java . lang . IDENT_1 > validator = new java . util . concurrent . METHOD_1 ( ) ; final com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_4 IDENT_5 = com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . IDENT_7 . METHOD_2 ( com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . IDENT_8 , com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . IDENT_9 , com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_10 . METHOD_3 ( ) ) ; IDENT_5 . METHOD_4 ( java . time . IDENT_11 . METHOD_5 ( 5 ) ) ; try { final com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_12 IDENT_13 = com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . IDENT_14 . METHOD_6 ( ) ; int count = 0 ; while ( true ) { final com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_15 IDENT_16 = com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_15 . create ( new java . lang . String ( new char [ INT_0 ] ) . replace ( STRING_0 , "a" ) . getBytes ( ) ) ; for ( int i = 0 ; i < ( new java . util . METHOD_7 ( ) . METHOD_8 ( 20 ) ) ; i ++ ) IDENT_16 . METHOD_9 ( ) . put ( ( STRING_1 + i ) , STRING_2 ) ; if ( IDENT_13 . METHOD_10 ( IDENT_16 ) ) count ++ ; else break ; } "<AssertPlaceHolder>" ; IDENT_5 . METHOD_11 ( new com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . METHOD_12 ( validator , count ) ) ; com . microsoft . azure . IDENT_2 . IDENT_3 . IDENT_6 . IDENT_14 . METHOD_13 ( IDENT_13 ) ; validator . get ( 100 , TimeUnit . IDENT_17 ) ; IDENT_5 . METHOD_11 ( null ) ; } finally { IDENT_5 . METHOD_14 ( ) ; } } METHOD_15 ( ) { return events . size ( ) ; }
org . junit . Assert . assertEquals ( count , IDENT_13 . METHOD_15 ( ) )