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