METHOD_0 ( ) { org . IDENT_0 . nio . test . IDENT_1 . log . info ( STRING_0 ) ; final java . util . concurrent . IDENT_2 IDENT_3 = new java . util . concurrent . METHOD_1 ( 2 ) ; final java . util . concurrent . atomic . IDENT_4 IDENT_5 = new java . util . concurrent . atomic . METHOD_2 ( 0 ) ; final java . util . concurrent . atomic . METHOD_2 IDENT_6 = new java . util . concurrent . atomic . METHOD_2 ( 0 ) ; METHOD_3 ( new org . IDENT_0 . nio . test . IDENT_1 . METHOD_4 ( IDENT_3 ) , new org . IDENT_0 . IDENT_7 < IDENT_8 > ( ) { public void METHOD_5 ( final IDENT_8 channel ) { channel . METHOD_6 ( ) . set ( new org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_10 > ( ) { public void METHOD_5 ( final org . IDENT_0 . IDENT_9 . IDENT_10 channel ) { IDENT_3 . METHOD_7 ( ) ; } } ) ; channel . METHOD_8 ( ) . set ( new org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_10 > ( ) { public void METHOD_5 ( final org . IDENT_0 . IDENT_9 . IDENT_10 channel ) { try { int c ; while ( ( c = channel . read ( java . nio . ByteBuffer . METHOD_9 ( 100 ) ) ) > 0 ) { IDENT_5 . METHOD_10 ( c ) ; } if ( c == ( - 1 ) ) { org . IDENT_0 . IDENT_11 . METHOD_11 ( channel ) ; } } catch ( java . lang . Throwable t ) { org . IDENT_0 . nio . test . IDENT_1 . log . METHOD_12 ( t , STRING_1 ) ; throw new java . lang . RuntimeException ( t ) ; } } } ) ; final java . nio . ByteBuffer buffer = java . nio . ByteBuffer . METHOD_9 ( 100 ) ; try { buffer . put ( STRING_2 . getBytes ( STRING_3 ) ) . METHOD_13 ( ) ; } catch ( java . io . IDENT_12 e ) { throw new java . lang . RuntimeException ( e ) ; } channel . METHOD_14 ( ) ; } } , new org . IDENT_0 . IDENT_7 < T > ( ) { public void METHOD_5 ( final T channel ) { channel . METHOD_6 ( ) . set ( new org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_13 > ( ) { public void METHOD_5 ( final org . IDENT_0 . IDENT_9 . IDENT_13 channel ) { IDENT_3 . METHOD_7 ( ) ; } } ) ; final java . nio . ByteBuffer buffer = java . nio . ByteBuffer . METHOD_9 ( 100 ) ; try { buffer . put ( STRING_4 . getBytes ( STRING_3 ) ) . METHOD_13 ( ) ; } catch ( java . io . IDENT_12 e ) { throw new java . lang . RuntimeException ( e ) ; } channel . METHOD_15 ( ) . set ( new org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_13 > ( ) { public void METHOD_5 ( final org . IDENT_0 . IDENT_9 . IDENT_13 channel ) { try { int c ; while ( ( c = channel . write ( buffer ) ) > 0 ) { if ( ( IDENT_6 . METHOD_10 ( c ) ) > 1000 ) { final org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_13 > listener = new org . IDENT_0 . IDENT_7 < org . IDENT_0 . IDENT_9 . IDENT_13 > ( ) { public void METHOD_5 ( final org . IDENT_0 . IDENT_9 . IDENT_13 channel ) { try { org . IDENT_0 . IDENT_11 . METHOD_11 ( channel ) ; } catch ( java . lang . Throwable t ) { org . IDENT_0 . nio . test . IDENT_1 . log . METHOD_12 ( t , STRING_1 ) ; throw new java . lang . RuntimeException ( t ) ; } } } ; channel . METHOD_15 ( ) . set ( listener ) ; listener . METHOD_5 ( channel ) ; return ; } buffer . METHOD_16 ( ) ; } } catch ( java . lang . Throwable t ) { org . IDENT_0 . nio . test . IDENT_1 . log . METHOD_12 ( t , STRING_1 ) ; throw new java . lang . RuntimeException ( t ) ; } } } ) ; channel . METHOD_17 ( ) ; } } ) ; "<AssertPlaceHolder>" ; IDENT_14 . set ( true ) ; IDENT_15 . set ( true ) ; } get ( ) { return result ; }
org . junit . Assert . assertEquals ( IDENT_6 . get ( ) , IDENT_5 . get ( ) )