METHOD_0 ( ) { "<AssertPlaceHolder>" ; task . METHOD_1 ( ) ; } METHOD_2 ( ) { while ( ( ( ( METHOD_1 ) != null ) && ( ! ( METHOD_1 . get ( ) ) ) ) && ( ! ( policy . METHOD_3 ( ) ) ) ) { com . github . IDENT_0 . kafka . connect . fs . IDENT_1 . log . trace ( STRING_0 ) ; final com . github . IDENT_0 . kafka . connect . fs . List < org . apache . kafka . connect . source . IDENT_2 > results = new com . github . IDENT_0 . kafka . connect . fs . ArrayList ( ) ; com . github . IDENT_0 . kafka . connect . fs . List < com . github . IDENT_0 . kafka . connect . fs . file . IDENT_3 > IDENT_4 = METHOD_4 ( ) ; IDENT_4 . METHOD_5 ( ( metadata ) -> { try ( com . github . IDENT_0 . kafka . connect . fs . file . reader . IDENT_5 reader = policy . METHOD_6 ( metadata , com . github . IDENT_0 . kafka . connect . fs . context . METHOD_7 ( ) ) ) { com . github . IDENT_0 . kafka . connect . fs . IDENT_1 . log . info ( STRING_1 , metadata ) ; while ( reader . hasNext ( ) ) { results . add ( convert ( metadata , reader . METHOD_8 ( ) , reader . next ( ) ) ) ; } } catch ( org . apache . kafka . connect . errors . IDENT_6 | java . io . IOException e ) { com . github . IDENT_0 . kafka . connect . fs . IDENT_1 . log . error ( ( ( STRING_2 + ( metadata . getPath ( ) ) ) + STRING_3 ) , com . github . IDENT_0 . kafka . connect . fs . e ) ; } } ) ; return results ; } return null ; }
org . junit . Assert . assertNull ( task . METHOD_2 ( ) )