my $pipeline :promise = TQmap {
	open $out, '>', $outFile;
	write( $out, $_ ) while $Qin->dequeue;
	close $out;
} 1, 10, TQmap {
	while( $Qin->dequeue ) {
		my $encoded = encode( $_ ); 
		$Qout->enqueue( $encoded );
	}
} 2, 20, TQmap {
	while( $Qin->dequeue ) {
		my $transformed = transform( $_ ); 
		$Qout->enqueue( $transformed );
	}
}, 4, 40, TQmap {
	while( $Qin->dequeue ) {
		my $decoded = decode( $_ );
		$Qout->enqueue( $decoded );
	}
}, 2, 20, TQmap { 
	## read
	open my $in, '<'. $inFile;
	$Qout->enqueue( $_ ) while <$in>;
	close $in;
}, 1, 10, undef;

monitorKeyboard() until defined $pipeline;

if( $pipeline != SUCCESS ) {
	log( error, $pipeline );
}
else {
	log( success, $pipeline );
}

exit;