--- a/src/CSVCommand.cpp	Wed Sep 23 11:23:12 2020 +0200
+++ b/src/CSVCommand.cpp	Wed Sep 23 11:26:33 2020 +0200
@@ -87,9 +87,8 @@
 	return false;
 }
 
-void CSVCommand::processDataStream(std::ostream& output, std::istream& input, const vector<relpipe::writer::string_t>& args) {
+void CSVCommand::process(std::istream& input, const vector<relpipe::writer::string_t>& args, std::shared_ptr<writer::RelationalWriter> writer) {
 	wstring_convert < codecvt_utf8<wchar_t>> convertor; // UTF-8 is required for CSV
-	std::shared_ptr<RelationalWriter> writer(Factory::create(output));
 	vector<AttributeMetadata> metadata;
 	bool headerDone = false;
 	bool lastInRecord = false;