$water = {
map
{
    my $process = $_;
    my @inputs = @ {$processes{$process}[1]};
    $_, {
	prerequisites => [ @inputs ],
	oo_output =>
	    sub
	    {
		my ($data) = shift;
		my ($pid, @fh, $active);
		@fh = map { $data->get($_) } @inputs;
                push @fh, \*STDIN if ((defined $start) and $start eq $process);
                $active = scalar @fh;
		local (*IN, *OUT, $/, $\);
		$/ = 1;
		$\ = '';
		open2 \*OUT, \*IN, $processes{$process}[0];
		select(IN);
		for (;;)
		{
		    my $piece = join '', map { (eof $_) ? "\0" : <$_> } @fh;
		    (grep { not eof $_ } @fh) ? (print $piece) : (last);
		}
		close (IN);
		return \*OUT;
            } } } keys %processes };

tie %river, 'Data::Flow', $water;
{
    my $output = $river{$final};
    local $/ = undef;
    local $_;
    $_ = <$output>;
    print;
}
exit 0;