METHOD_0 ( ) { java . lang . String request = STRING_0 ; java . lang . String response = STRING_1 ; java . lang . String result = STRING_2 ; org . apache . IDENT_0 . IDENT_1 . impl . channel . IDENT_2 IDENT_3 = mock ( org . apache . IDENT_0 . IDENT_1 . impl . channel . IDENT_2 . class ) ; java . util . concurrent . IDENT_4 < org . apache . IDENT_0 . IDENT_1 . impl . channel . IDENT_2 > IDENT_5 = new java . util . concurrent . METHOD_1 ( ) ; when ( IDENT_6 . METHOD_2 ( ) ) . thenReturn ( IDENT_5 ) ; java . util . concurrent . atomic . IDENT_7 IDENT_8 = new java . util . concurrent . atomic . METHOD_3 ( 0 ) ; when ( processor . METHOD_4 ( ) ) . thenReturn ( request ) ; when ( processor . METHOD_5 ( eq ( response ) ) ) . thenReturn ( result ) ; when ( processor . METHOD_6 ( METHOD_7 ( IDENT_3 ) , eq ( request ) ) ) . METHOD_8 ( ( IDENT_9 ) -> { IDENT_10 < java . lang . String > IDENT_11 = com . google . common . util . concurrent . IDENT_10 . create ( ) ; if ( ( IDENT_8 . METHOD_9 ( ) ) > 2 ) { IDENT_11 . set ( response ) ; } else { IDENT_11 . METHOD_10 ( new io . grpc . METHOD_11 ( Status . IDENT_12 ) ) ; } return IDENT_11 ; } ) ; java . util . concurrent . METHOD_1 < java . lang . String > IDENT_13 = processor . process ( ) ; org . apache . IDENT_0 . common . concurrent . IDENT_14 . METHOD_12 ( IDENT_5 , IDENT_3 ) ; "<AssertPlaceHolder>" ; verify ( IDENT_6 , times ( 4 ) ) . METHOD_2 ( ) ; } result ( java . util . concurrent . METHOD_1 ) { return org . apache . IDENT_0 . common . concurrent . IDENT_14 . result ( future , org . apache . IDENT_0 . common . concurrent . IDENT_14 . IDENT_15 ) ; }
org . junit . Assert . assertEquals ( result , org . apache . IDENT_0 . common . concurrent . IDENT_14 . result ( IDENT_13 ) )