Function dataflow::source::read_file_task

pub fn read_file_task<Ctor, I, Err>(
    path: PathBuf, 
    tx: SyncSender<Result<MessagePayload, Error>>, 
    activator: Option<SyncActivator>, 
    read_style: FileReadStyle, 
    compression: Compression, 
    iter_ctor: Ctor
) where
    I: IntoIterator<Item = Result<MessagePayload, Err>> + Send + 'static,
    Ctor: FnOnce(Box<dyn AvroRead + Send>) -> Result<I, Err>,
    Err: Into<Error>, 

Blocking logic to read from a file, intended for its own thread.