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