METHOD_0 ( ) { METHOD_1 ( org . apache . IDENT_0 . stream . storage . impl . service . IDENT_1 . IDENT_2 ) ; org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 IDENT_7 = org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . METHOD_2 ( ) ; when ( IDENT_8 . METHOD_3 ( any ( org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_9 . class ) ) ) . thenReturn ( org . apache . IDENT_0 . common . concurrent . IDENT_10 . value ( IDENT_7 ) ) ; container . METHOD_4 ( ) . METHOD_5 ( ) . put ( org . apache . IDENT_0 . stream . storage . impl . service . IDENT_1 . IDENT_11 , IDENT_8 ) ; org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_9 request = METHOD_6 ( ) ; org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 response = org . apache . IDENT_0 . common . concurrent . IDENT_10 . result ( container . METHOD_3 ( request ) ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_9 ) { org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_12 header = request . METHOD_7 ( ) ; if ( ( header . METHOD_8 ( ) ) <= 0L ) { return java . util . concurrent . IDENT_13 . METHOD_9 ( org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_6 . METHOD_10 ( ) . METHOD_11 ( org . apache . IDENT_0 . stream . IDENT_3 . IDENT_4 . IDENT_5 . IDENT_14 . METHOD_10 ( ) . METHOD_12 ( IDENT_15 . IDENT_16 ) . METHOD_13 ( request . METHOD_7 ( ) ) . build ( ) ) . build ( ) ) ; } org . apache . IDENT_0 . stream . protocol . IDENT_17 IDENT_18 = org . apache . IDENT_0 . stream . protocol . IDENT_17 . of ( header . METHOD_14 ( ) , header . METHOD_8 ( ) ) ; org . apache . IDENT_0 . stream . storage . api . IDENT_4 . IDENT_19 store = IDENT_20 . METHOD_15 ( IDENT_18 ) ; if ( null != store ) { return store . METHOD_3 ( request ) ; } else { return IDENT_20 . METHOD_16 ( IDENT_21 , IDENT_18 ) . METHOD_17 ( ( s ) -> s . METHOD_3 ( request ) ) ; } }
org . junit . Assert . assertSame ( IDENT_7 , response )