METHOD_0 ( ) { final java . util . concurrent . IDENT_0 < org . apache . flink . runtime . messages . IDENT_1 > future = org . apache . flink . runtime . concurrent . IDENT_2 . METHOD_1 ( IDENT_1 :: get , org . apache . flink . runtime . IDENT_3 . IDENT_4 . METHOD_2 ( ) ) ; "<AssertPlaceHolder>" ; } get ( ) { return delegate . get ( ) ; }
org . junit . Assert . assertThat ( future . get ( ) , org . hamcrest . Matchers . is ( org . apache . flink . runtime . messages . IDENT_1 . get ( ) ) )