METHOD_0 ( ) { io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 . IDENT_4 IDENT_5 = new io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 . METHOD_1 ( ) ; java . util . UUID IDENT_6 = io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_7 . METHOD_2 ( ) ; io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_8 IDENT_9 = io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_8 . builder ( ) . METHOD_3 ( IDENT_10 . METHOD_4 ( ) ) . METHOD_5 ( IDENT_11 , true ) . METHOD_6 ( new io . IDENT_0 . IDENT_1 . buffer . METHOD_7 ( java . nio . ByteBuffer . METHOD_8 ( ( 16 * INT_0 ) ) . order ( java . nio . IDENT_12 . METHOD_9 ( ) ) ) ) . METHOD_10 ( IDENT_5 ) . METHOD_11 ( IDENT_13 . IDENT_14 ) . METHOD_12 ( IDENT_6 ) . METHOD_13 ( IDENT_15 . getBytes ( ) ) . METHOD_14 ( INT_1 ) . build ( ) ; io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_16 future = new io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_15 ( IDENT_6 , IDENT_10 . METHOD_4 ( ) ) ; IDENT_9 . METHOD_16 ( ) ; future . get ( INT_2 , TimeUnit . IDENT_17 ) ; java . nio . ByteBuffer buf = java . nio . ByteBuffer . METHOD_8 ( INT_3 ) . order ( java . nio . IDENT_12 . METHOD_9 ( ) ) ; int IDENT_18 = 0 ; for ( int i = 0 ; i < ( IDENT_19 ) ; ++ i ) { buf . METHOD_17 ( ) ; IDENT_18 += METHOD_18 ( buf , messages [ i ] ) ; IDENT_9 . METHOD_19 ( buf ) ; } try { java . lang . Thread . sleep ( 1000 ) ; } catch ( java . lang . IDENT_20 e ) { } int IDENT_21 = 0 ; for ( io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_3 . METHOD_1 t : IDENT_22 . METHOD_20 ( ) ) { IDENT_21 += t . METHOD_21 ( ) ; } "<AssertPlaceHolder>" ; io . IDENT_0 . IDENT_1 . IDENT_2 . IDENT_23 IDENT_24 = new io . IDENT_0 . IDENT_1 . IDENT_2 . METHOD_22 ( IDENT_6 , IDENT_10 . METHOD_4 ( ) ) ; IDENT_9 . close ( ) ; future . get ( 1000 , TimeUnit . IDENT_17 ) ; } METHOD_21 ( ) { return IDENT_25 ; }
org . junit . Assert . assertEquals ( IDENT_19 , IDENT_21 )