/ 
Data-Tubes-0.69_00
River stage one • 1 direct dependent • 1 total dependent
/ Data::Tubes::Plugin::Reader

NAME

Data::Tubes::Plugin::Reader

DESCRIPTION

This module contains factory functions to generate tubes that ease reading of input records.

Each of the generated tubes has the following contract:

  • the input record MUST be a hash reference;

  • depending on the presence of an argument input, the record itself or the sub-hash indicated by input MUST contain a field fh with a filehandle. By default, the input field is set to source;

  • one field in the hash (according to factory argument output, set to raw by default) is set to the output of the reading operation.

The factory functions below have two names, one starting with read_ and the other without this prefix. They are perfectly equivalent to each other, whereas the short version can be handier e.g. when using tube or pipeline from Data::Tubes.

FUNCTIONS

by_line
read_by_line

This is a simple wrapper around "read_by_separator", where the separator argument is forced to be a newline \n.

by_paragraph
read_by_paragraph

This is a simple wrapper around "read_by_separator", where the separator argument is forced to be the empty string.

by_record_reader
read_by_record_reader
my $tube = by_record_reader(%args); # OR
my $tube = by_record_reader(\%args);

read inputs according to a record reader subroutine.

Accepted arguments are:

emit_eof

when an end-of-file is hit, emit a record with the output field set to undef, so that this condition will be visible in the tubes on the downstream;

identification

you don't normally need to use this... so look at the code in case you have to;

input

name of the input field in the record. If defined and not empty, it points to a sub-hash that will contain a filehandle field fh; otherwise, this fh field MUST be contained directly in the input record contents. Defaults to source;

name

name of the tube, for easier debugging;

output

name of the output field. The output record is ALWAYS a hash reference, containing the input record and the output correponding to this key. Defaults to c<raw>;

record_reader

a sub reference that takes a filehandle as the only input parameter, and returns whatever is read.

by_separator
read_by_separator
my $tube = by_separator(%args); # OR
my $tube = by_separator(\%args);

read inputs setting a separator string (a-la INPUT_RECORD_SEPARATOR, see perlvar).

Accepted arguments are:

chomp

apply the chomp function before emitting what's read;

emit_eof

when an end-of-file is hit, emit a record with the output field set to undef, so that this condition will be visible in the tubes on the downstream;

identification

you don't normally need to use this... so look at the code in case you have to;

input

name of the input field in the record. If defined and not empty, it points to a sub-hash that will contain a filehandle field fh; otherwise, this fh field MUST be contained directly in the input record contents. Defaults to source;

name

name of the tube, for easier debugging;

output

name of the output field. The output record is ALWAYS a hash reference, containing the input record and the output correponding to this key. Defaults to c<raw>;

separator

a separator string to set as INPUT_RECORD_SEPARATOR, see perlvar.

BUGS AND LIMITATIONS

Report bugs either through RT or GitHub (patches welcome).

AUTHOR

Flavio Poletti <polettix@cpan.org>

COPYRIGHT AND LICENSE

Copyright (C) 2016 by Flavio Poletti <polettix@cpan.org>

This module is free software. You can redistribute it and/or modify it under the terms of the Artistic License 2.0.

This program is distributed in the hope that it will be useful, but without any warranty; without even the implied warranty of merchantability or fitness for a particular purpose.