METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 IDENT_1 = new java . util . concurrent . atomic . METHOD_1 ( ) ; io . grpc . netty . IDENT_2 handler = new io . grpc . netty . METHOD_2 ( new io . netty . channel . METHOD_3 ( ) { @ io . grpc . netty . Override public void close ( io . netty . channel . IDENT_3 ctx , io . netty . channel . IDENT_4 IDENT_5 ) throws java . lang . Exception { IDENT_1 . METHOD_4 ( ) ; ctx . METHOD_5 ( Status . IDENT_6 . METHOD_6 ( STRING_0 ) . METHOD_7 ( ) ) ; super . close ( ctx , IDENT_5 ) ; } } ) ; io . netty . channel . IDENT_7 . IDENT_8 IDENT_9 = new io . netty . channel . IDENT_7 . METHOD_8 ( STRING_1 ) ; io . netty . channel . IDENT_10 IDENT_11 = new io . netty . IDENT_12 . METHOD_9 ( ) . channel ( io . netty . channel . IDENT_7 . IDENT_13 . class ) . handler ( handler ) . group ( group ) . METHOD_10 ( ) ; IDENT_14 = IDENT_11 . channel ( ) ; IDENT_11 . sync ( ) ; io . netty . channel . IDENT_10 sf = new io . netty . IDENT_12 . METHOD_11 ( ) . channel ( io . netty . channel . IDENT_7 . IDENT_15 . class ) . METHOD_12 ( new io . netty . channel . METHOD_13 ( ) { } ) . group ( group ) . METHOD_14 ( IDENT_9 ) ; server = sf . channel ( ) ; sf . sync ( ) ; IDENT_14 . connect ( IDENT_9 ) . sync ( ) ; IDENT_14 . close ( ) . sync ( ) ; "<AssertPlaceHolder>" ; } get ( ) { return io . grpc . IDENT_16 . IDENT_17 . IDENT_18 ; }
org . junit . Assert . assertEquals ( 1 , IDENT_1 . get ( ) )