METHOD_0 ( ) { final java . util . concurrent . atomic . IDENT_0 count = new java . util . concurrent . atomic . METHOD_1 ( ) ; io . IDENT_1 . IDENT_2 . METHOD_2 ( 3 , 2 , 5 ) . METHOD_3 ( com . github . davidmoten . IDENT_3 . IDENT_4 . IDENT_5 . < java . lang . Integer > METHOD_4 ( 2 ) ) . METHOD_5 ( new org . IDENT_6 . IDENT_7 < java . lang . Integer > ( ) { MOD_0 org . IDENT_6 . IDENT_8 s ; @ com . github . davidmoten . IDENT_3 . internal . IDENT_4 . Override public void METHOD_6 ( org . IDENT_6 . IDENT_8 s ) { this . s = s ; s . request ( Long . MAX_VALUE ) ; } @ com . github . davidmoten . IDENT_3 . internal . IDENT_4 . Override public void METHOD_7 ( java . lang . Integer t ) { count . METHOD_8 ( ) ; s . METHOD_9 ( ) ; } @ com . github . davidmoten . IDENT_3 . internal . IDENT_4 . Override public void METHOD_10 ( java . lang . Throwable t ) { } @ com . github . davidmoten . IDENT_3 . internal . IDENT_4 . Override public void METHOD_11 ( ) { } } ) ; "<AssertPlaceHolder>" ; } get ( ) { com . github . davidmoten . IDENT_9 . IDENT_10 . METHOD_12 ( t ) ; return t ; }
org . junit . Assert . assertEquals ( 1 , count . get ( ) )