METHOD_0 ( ) { org . IDENT_0 . IDENT_1 IDENT_2 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . METHOD_1 IDENT_3 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . METHOD_1 IDENT_4 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . METHOD_1 IDENT_5 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . METHOD_1 IDENT_6 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . METHOD_1 IDENT_7 = new org . IDENT_0 . METHOD_1 ( ) . METHOD_2 ( ) . METHOD_3 ( ) . METHOD_4 ( ) ; org . IDENT_0 . IDENT_8 IDENT_9 = new org . IDENT_0 . METHOD_5 ( ) . METHOD_6 ( IDENT_2 , IDENT_5 ) . METHOD_6 ( IDENT_3 , IDENT_6 ) . METHOD_6 ( IDENT_4 , IDENT_7 ) ; org . IDENT_0 . METHOD_5 . IDENT_10 process = IDENT_9 . run ( ) ; org . IDENT_0 . config . IDENT_11 config = new org . IDENT_0 . config . METHOD_7 ( ) ; config . METHOD_8 ( ) . METHOD_9 ( IDENT_12 . IDENT_13 ) . METHOD_10 ( new org . IDENT_0 . connection . IDENT_14 . METHOD_11 ( ) ) . METHOD_12 ( process . METHOD_13 ( ) . stream ( ) . METHOD_14 ( ) . get ( ) . METHOD_15 ( ) ) ; org . IDENT_0 . api . IDENT_15 IDENT_0 = org . IDENT_0 . IDENT_16 . create ( config ) ; final java . util . concurrent . atomic . IDENT_17 IDENT_18 = new java . util . concurrent . atomic . METHOD_16 ( ) ; final java . util . concurrent . atomic . IDENT_19 IDENT_20 = new java . util . concurrent . atomic . METHOD_17 ( ) ; org . IDENT_0 . api . IDENT_21 IDENT_22 = IDENT_0 . METHOD_18 ( STRING_0 ) ; IDENT_22 . METHOD_19 ( new org . IDENT_0 . api . listener . METHOD_20 ( ) { @ org . IDENT_0 . Override public void METHOD_21 ( java . lang . String channel ) { } @ org . IDENT_0 . Override public void METHOD_22 ( java . lang . String channel ) { IDENT_20 . METHOD_23 ( ) ; } } ) ; IDENT_22 . METHOD_19 ( org . IDENT_0 . Integer . class , new org . IDENT_0 . api . listener . IDENT_23 < java . lang . Integer > ( ) { @ org . IDENT_0 . Override public void METHOD_24 ( java . lang . IDENT_24 channel , java . lang . Integer msg ) { IDENT_18 . set ( true ) ; } } ) ; METHOD_25 ( IDENT_0 , STRING_0 ) ; process . METHOD_13 ( ) . stream ( ) . filter ( ( x ) -> ( IDENT_2 . METHOD_26 ( ) ) == ( x . METHOD_27 ( ) ) ) . METHOD_28 ( ( x ) -> { try { x . METHOD_29 ( ) ; java . lang . Thread . sleep ( INT_0 ) ; } catch ( e ) { org . IDENT_0 . e . printStackTrace ( ) ; } } ) ; java . lang . Thread . sleep ( INT_1 ) ; IDENT_0 . METHOD_18 ( STRING_0 ) . METHOD_30 ( 1 ) ; METHOD_31 ( ) . METHOD_32 ( INT_2 , TimeUnit . IDENT_25 ) . METHOD_33 ( ( ) -> ( IDENT_20 . get ( ) ) == 2 ) ; "<AssertPlaceHolder>" ; IDENT_0 . METHOD_34 ( ) ; process . METHOD_34 ( ) ; } get ( ) { return null ; }
org . junit . Assert . assertTrue ( IDENT_18 . get ( ) )