METHOD_0 ( ) { io . vertx . ext . IDENT_0 . impl . IDENT_1 IDENT_2 = new io . vertx . ext . IDENT_0 . impl . METHOD_1 ( ) ; server . close ( IDENT_2 . handler ( ) ) ; IDENT_2 . METHOD_2 ( ) ; IDENT_2 = new io . vertx . ext . IDENT_0 . impl . METHOD_1 ( ) ; server = io . vertx . ext . IDENT_0 . impl . IDENT_3 . create ( vertx , new io . vertx . ext . IDENT_0 . impl . METHOD_3 ( ) . METHOD_4 ( new io . vertx . core . json . METHOD_5 ( ) . put ( STRING_0 , 1000 ) . put ( STRING_1 , 1000 ) ) ) . handler ( io . vertx . ext . IDENT_0 . impl . IDENT_4 . create ( vertx ) ) . METHOD_6 ( IDENT_2 . handler ( ) ) ; IDENT_2 . METHOD_2 ( ) ; io . vertx . ext . IDENT_0 . impl . IDENT_5 client = io . vertx . ext . IDENT_0 . impl . IDENT_5 . create ( vertx , new io . vertx . ext . IDENT_0 . impl . METHOD_7 ( ) . METHOD_4 ( new io . vertx . core . json . METHOD_5 ( ) . put ( STRING_0 , 1000 ) . put ( STRING_1 , 1000 ) ) ) ; java . util . concurrent . atomic . IDENT_6 IDENT_7 = new java . util . concurrent . atomic . METHOD_8 ( ) ; java . util . concurrent . atomic . METHOD_8 IDENT_8 = new java . util . concurrent . atomic . METHOD_8 ( ) ; client . connect ( ( connection ) -> { connection . result ( ) . METHOD_9 ( ( conn ) -> { IDENT_7 . set ( true ) ; } ) ; IDENT_8 . set ( connection . METHOD_10 ( ) ) ; } ) ; METHOD_11 ( ) . METHOD_12 ( 10 , TimeUnit . IDENT_9 ) . METHOD_13 ( IDENT_8 :: get ) ; client . close ( ) ; java . util . concurrent . atomic . METHOD_8 IDENT_10 = new java . util . concurrent . atomic . METHOD_8 ( ) ; vertx . METHOD_14 ( 1000 , ( l ) -> { IDENT_10 . set ( true ) ; } ) ; METHOD_11 ( ) . METHOD_12 ( 10 , TimeUnit . IDENT_9 ) . METHOD_13 ( IDENT_10 :: get ) ; "<AssertPlaceHolder>" . METHOD_15 ( ) ; } close ( ) { METHOD_16 ( ) ; handler ( ) . METHOD_17 ( this ) ; try { IDENT_11 . close ( ) ; } catch ( java . lang . IllegalStateException e ) { } }
org . junit . Assert . assertThat ( IDENT_7 . get ( ) )