METHOD_0 ( ) { final io . IDENT_0 . IDENT_1 . util . IDENT_2 IDENT_3 = new io . IDENT_0 . IDENT_1 . util . METHOD_1 ( com . google . common . collect . ImmutableMap . of ( IDENT_4 . IDENT_5 , IDENT_4 . IDENT_6 , METHOD_1 . IDENT_7 , METHOD_1 . IDENT_8 ) ) ; when ( IDENT_9 . METHOD_2 ( IDENT_10 , IDENT_11 ) ) . thenReturn ( IDENT_12 ) ; final org . apache . kafka . streams . IDENT_13 . IDENT_14 < java . lang . String , io . IDENT_0 . IDENT_1 . IDENT_15 , org . apache . kafka . streams . processor . IDENT_16 > IDENT_17 = io . IDENT_0 . IDENT_1 . streams . IDENT_18 . create ( IDENT_3 , IDENT_9 ) . create ( IDENT_10 , IDENT_11 , io . IDENT_0 . IDENT_1 . streams . IDENT_19 . IDENT_20 ) ; "<AssertPlaceHolder>" ; verify ( IDENT_9 ) . METHOD_2 ( IDENT_10 , IDENT_11 ) ; } create ( io . IDENT_0 . IDENT_1 . rest . client . IDENT_21 , io . IDENT_0 . IDENT_1 . util . IDENT_22 ) { return new io . IDENT_0 . IDENT_1 . cli . IDENT_23 . IDENT_24 . METHOD_3 ( IDENT_25 , IDENT_26 ) ; }
org . junit . Assert . assertThat ( IDENT_17 , org . hamcrest . Matchers . is ( IDENT_12 ) )