2016-05-28 18:54:17 +01:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include "Sink.h"
|
|
|
|
|
|
|
|
namespace Net {
|
|
|
|
/*
|
|
|
|
* Sink object for downloads that uses an external QByteArray it doesn't own as a target.
|
|
|
|
*/
|
|
|
|
class ByteArraySink : public Sink
|
|
|
|
{
|
|
|
|
public:
|
2018-07-15 13:51:05 +01:00
|
|
|
ByteArraySink(QByteArray *output)
|
|
|
|
:m_output(output)
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
};
|
2016-05-28 18:54:17 +01:00
|
|
|
|
2018-07-15 13:51:05 +01:00
|
|
|
virtual ~ByteArraySink()
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
}
|
2016-05-28 18:54:17 +01:00
|
|
|
|
|
|
|
public:
|
2018-07-15 13:51:05 +01:00
|
|
|
JobStatus init(QNetworkRequest & request) override
|
|
|
|
{
|
|
|
|
m_output->clear();
|
|
|
|
if(initAllValidators(request))
|
|
|
|
return Job_InProgress;
|
|
|
|
return Job_Failed;
|
|
|
|
};
|
|
|
|
|
|
|
|
JobStatus write(QByteArray & data) override
|
|
|
|
{
|
|
|
|
m_output->append(data);
|
|
|
|
if(writeAllValidators(data))
|
|
|
|
return Job_InProgress;
|
|
|
|
return Job_Failed;
|
|
|
|
}
|
|
|
|
|
|
|
|
JobStatus abort() override
|
|
|
|
{
|
|
|
|
m_output->clear();
|
|
|
|
failAllValidators();
|
|
|
|
return Job_Failed;
|
|
|
|
}
|
|
|
|
|
|
|
|
JobStatus finalize(QNetworkReply &reply) override
|
|
|
|
{
|
|
|
|
if(finalizeAllValidators(reply))
|
|
|
|
return Job_Finished;
|
|
|
|
return Job_Failed;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool hasLocalData() override
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
2016-10-28 01:19:19 +01:00
|
|
|
|
2016-05-28 18:54:17 +01:00
|
|
|
private:
|
2018-07-15 13:51:05 +01:00
|
|
|
QByteArray * m_output;
|
2016-05-28 18:54:17 +01:00
|
|
|
};
|
|
|
|
}
|