question: returns a future that represents a computation that drains the stdout of the child process . that future 's result is true if the end of the child 's stdout is reached , its result is false if there was an error while reading from the stream . this task will log all the lines it drains to permit debugging . concode_field_sep ObjectMapper objectMapper concode_elem_sep ExecutorService executorService concode_elem_sep BufferedReader reader concode_elem_sep String shardId concode_field_sep Future<Message> getNextMessageFromSTDOUT concode_elem_sep MessageReader initialize concode_elem_sep MessageReader initialize
target: Future < Boolean > function ( ) { DrainChildSTDOUTTask loc0 = new DrainChildSTDOUTTask ( ) ; loc0 . initialize ( reader , shardId ) ; return this . executorService . submit ( loc0 ) ; }