2016-05-28 23:24:17 +05:30
|
|
|
#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 18:21:05 +05:30
|
|
|
ByteArraySink(QByteArray *output)
|
|
|
|
:m_output(output)
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
};
|
2016-05-28 23:24:17 +05:30
|
|
|
|
2018-07-15 18:21:05 +05:30
|
|
|
virtual ~ByteArraySink()
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
}
|
2016-05-28 23:24:17 +05:30
|
|
|
|
|
|
|
public:
|
2018-07-15 18:21:05 +05:30
|
|
|
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 05:49:19 +05:30
|
|
|
|
2016-05-28 23:24:17 +05:30
|
|
|
private:
|
2018-07-15 18:21:05 +05:30
|
|
|
QByteArray * m_output;
|
2016-05-28 23:24:17 +05:30
|
|
|
};
|
|
|
|
}
|