METHOD_0 ( ) { com . IDENT_0 . entity . IDENT_1 in = com . IDENT_0 . TestUtils . METHOD_1 ( setName ) ; in . IDENT_2 = 0 ; final com . IDENT_0 . IDENT_3 IDENT_4 = IDENT_5 . create ( in ) . now ( ) ; com . IDENT_0 . IDENT_6 executor = com . IDENT_0 . IDENT_7 . METHOD_2 ( 5 , com . IDENT_0 . IDENT_7 . METHOD_3 ( ) ) ; java . util . List < com . IDENT_0 . IDENT_8 > IDENT_9 = new java . util . ArrayList ( ) ; int IDENT_10 = 1000 ; for ( int x = 0 ; x < IDENT_10 ; x ++ ) { com . IDENT_0 . IDENT_8 < ? > future = executor . METHOD_4 ( new java . lang . METHOD_5 ( ) { @ com . IDENT_0 . Override public void run ( ) { IDENT_5 . METHOD_6 ( 15 , new com . IDENT_0 . IDENT_11 < com . IDENT_0 . entity . IDENT_1 > ( ) { @ com . IDENT_0 . Override public com . IDENT_0 . entity . IDENT_1 run ( ) { com . IDENT_0 . entity . IDENT_1 out = IDENT_5 . get ( com . IDENT_0 . entity . IDENT_1 . class ) . key ( IDENT_4 ) . now ( ) ; ( out . IDENT_2 ) ++ ; IDENT_5 . update ( out ) . now ( ) ; return null ; } } ) ; } } ) ; IDENT_9 . add ( future ) ; } for ( com . IDENT_0 . IDENT_8 future : IDENT_9 ) { try { future . get ( ) ; } catch ( java . lang . IDENT_12 | com . IDENT_0 . IDENT_13 e ) { e . printStackTrace ( ) ; } } com . IDENT_0 . entity . IDENT_1 out = IDENT_5 . get ( com . IDENT_0 . entity . IDENT_1 . class ) . key ( IDENT_4 ) . now ( ) ; "<AssertPlaceHolder>" ; executor . METHOD_7 ( ) ; } now ( ) { METHOD_8 ( ) ; com . IDENT_14 . client . query . IDENT_15 statement = new com . IDENT_14 . client . query . METHOD_9 ( ) ; statement . METHOD_10 ( IDENT_16 ) ; statement . METHOD_11 ( IDENT_17 ) ; statement . METHOD_12 ( setName ) ; statement . METHOD_13 ( filters ) ; com . IDENT_14 . client . query . IDENT_18 IDENT_19 = IDENT_20 . query ( policy , statement ) ; return new com . IDENT_0 . ResultSet ( mapper , IDENT_21 , IDENT_22 , IDENT_19 , IDENT_20 ) ; }
org . junit . Assert . assertEquals ( IDENT_10 , out . IDENT_2 )