METHOD_0 ( ) { java . util . concurrent . IDENT_0 IDENT_1 = mock ( java . util . concurrent . IDENT_0 . class ) ; java . util . concurrent . IDENT_2 IDENT_3 = mock ( java . util . concurrent . IDENT_2 . class ) ; when ( IDENT_1 . METHOD_1 ( any ( org . apache . flink . runtime . IDENT_4 . IDENT_5 . IDENT_6 . class ) , METHOD_2 ( ) , any ( java . util . concurrent . TimeUnit . class ) ) ) . thenReturn ( IDENT_3 ) ; org . apache . flink . runtime . IDENT_4 . IDENT_5 . IDENT_7 < org . apache . flink . runtime . IDENT_8 . types . IDENT_9 > IDENT_10 = new org . apache . flink . runtime . IDENT_4 . IDENT_5 . METHOD_3 ( IDENT_1 , INT_0 ) ; org . apache . flink . runtime . IDENT_4 . IDENT_5 . IDENT_11 < org . apache . flink . runtime . IDENT_8 . types . IDENT_9 > listener = mock ( org . apache . flink . runtime . IDENT_4 . IDENT_5 . IDENT_11 . class ) ; IDENT_10 . start ( listener ) ; IDENT_10 . METHOD_4 ( new org . apache . flink . runtime . IDENT_8 . types . METHOD_5 ( ) , 10 , TimeUnit . IDENT_12 ) ; IDENT_10 . METHOD_4 ( new org . apache . flink . runtime . IDENT_8 . types . METHOD_5 ( ) , 10 , TimeUnit . IDENT_12 ) ; IDENT_10 . METHOD_6 ( ) ; java . util . Map < ? , ? > IDENT_13 = ( ( java . util . Map < ? , ? > ) ( org . apache . flink . mock . IDENT_14 . METHOD_7 ( IDENT_10 , STRING_0 ) ) ) ; "<AssertPlaceHolder>" ; verify ( IDENT_3 , times ( 2 ) ) . METHOD_8 ( true ) ; } isEmpty ( ) { return IDENT_15 . isEmpty ( ) ; }
org . junit . Assert . assertTrue ( IDENT_13 . isEmpty ( ) )