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 ( METHOD_1 . IDENT_4 , METHOD_1 . IDENT_5 ) ) ; when ( IDENT_6 . METHOD_2 ( io . IDENT_0 . IDENT_1 . streams . IDENT_7 . IDENT_8 , IDENT_9 , IDENT_10 ) ) . thenReturn ( IDENT_11 ) ; final org . apache . kafka . streams . IDENT_12 . IDENT_13 IDENT_14 = io . IDENT_0 . IDENT_1 . streams . IDENT_15 . create ( IDENT_3 , IDENT_6 ) . create ( io . IDENT_0 . IDENT_1 . streams . IDENT_7 . IDENT_8 , IDENT_9 , IDENT_10 ) ; "<AssertPlaceHolder>" ; verify ( IDENT_6 ) . METHOD_2 ( io . IDENT_0 . IDENT_1 . streams . IDENT_7 . IDENT_8 , IDENT_9 , IDENT_10 ) ; } create ( io . IDENT_0 . IDENT_1 . rest . client . IDENT_16 , io . IDENT_0 . IDENT_1 . util . IDENT_17 ) { return new io . IDENT_0 . IDENT_1 . cli . IDENT_18 . IDENT_19 . METHOD_3 ( IDENT_20 , IDENT_21 ) ; }
org . junit . Assert . assertThat ( IDENT_14 , org . hamcrest . Matchers . is ( IDENT_11 ) )