METHOD_0 ( ) { org . apache . kafka . streams . integration . utils . IDENT_0 . METHOD_1 ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_2 , java . util . Arrays . asList ( org . apache . kafka . streams . IDENT_3 . METHOD_2 ( 1 , 1 ) , org . apache . kafka . streams . IDENT_3 . METHOD_2 ( 2 , 2 ) , org . apache . kafka . streams . IDENT_3 . METHOD_2 ( 3 , 3 ) ) , org . apache . kafka . test . TestUtils . METHOD_3 ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_4 . METHOD_4 ( ) , org . apache . kafka . common . serialization . IDENT_5 . class , org . apache . kafka . common . serialization . IDENT_5 . class ) , org . apache . kafka . streams . integration . IDENT_1 . IDENT_4 . time ) ; final org . apache . kafka . streams . state . IDENT_6 IDENT_7 = org . apache . kafka . streams . state . IDENT_8 . METHOD_5 ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_2 , 10 ) ; final org . apache . kafka . streams . state . IDENT_9 < org . apache . kafka . streams . state . IDENT_10 < java . lang . Integer , java . lang . Integer > > IDENT_11 = new org . apache . kafka . streams . state . IDENT_12 . METHOD_6 ( IDENT_7 , org . apache . kafka . common . serialization . IDENT_13 . Integer ( ) , org . apache . kafka . common . serialization . IDENT_13 . Integer ( ) , org . apache . kafka . streams . integration . IDENT_1 . IDENT_4 . time ) . METHOD_7 ( ) ; final org . apache . kafka . streams . IDENT_14 IDENT_15 = new org . apache . kafka . streams . METHOD_8 ( ) ; IDENT_15 . METHOD_9 ( IDENT_11 ) ; final org . apache . kafka . streams . IDENT_16 . IDENT_17 < java . lang . Integer , java . lang . Integer > stream = IDENT_15 . stream ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_2 ) ; final java . util . concurrent . IDENT_18 IDENT_19 = new java . util . concurrent . METHOD_10 ( 3 ) ; stream . process ( ( ) -> new org . apache . kafka . streams . integration . METHOD_11 ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_2 , IDENT_19 ) , org . apache . kafka . streams . integration . IDENT_1 . IDENT_2 ) ; final org . apache . kafka . streams . IDENT_20 IDENT_21 = IDENT_15 . build ( ) ; IDENT_22 = new org . apache . kafka . streams . METHOD_12 ( IDENT_21 , props ( ( ( org . apache . kafka . streams . integration . IDENT_1 . IDENT_23 ) + STRING_0 ) ) ) ; final java . util . concurrent . METHOD_10 IDENT_24 = new java . util . concurrent . METHOD_10 ( 1 ) ; IDENT_22 . METHOD_13 ( ( IDENT_25 , IDENT_26 ) -> { if ( ( IDENT_25 == METHOD_12 . IDENT_27 . IDENT_28 ) && ( IDENT_26 == METHOD_12 . IDENT_27 . IDENT_29 ) ) { IDENT_24 . METHOD_14 ( ) ; } } ) ; IDENT_22 . start ( ) ; IDENT_24 . METHOD_15 ( INT_0 , TimeUnit . IDENT_30 ) ; "<AssertPlaceHolder>" ; } METHOD_15 ( long , java . util . concurrent . TimeUnit ) { long IDENT_31 = java . lang . System . currentTimeMillis ( ) ; long IDENT_32 = unit . METHOD_16 ( IDENT_33 ) ; long IDENT_34 = 0 ; MOD_0 ( this ) { while ( true ) { if ( ( exception ) != null ) org . apache . kafka . common . IDENT_12 . IDENT_35 . METHOD_17 ( exception ) ; if ( IDENT_36 ) return value ; if ( IDENT_34 >= IDENT_32 ) { throw new java . util . concurrent . METHOD_18 ( ) ; } this . METHOD_19 ( ( IDENT_32 - IDENT_34 ) ) ; IDENT_34 = ( java . lang . System . currentTimeMillis ( ) ) - IDENT_31 ; } } }
org . junit . Assert . assertTrue ( IDENT_19 . METHOD_15 ( INT_0 , TimeUnit . IDENT_30 ) )