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:
|
|
|
|
ByteArraySink(QByteArray *output)
|
|
|
|
:m_output(output)
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
};
|
|
|
|
|
|
|
|
virtual ~ByteArraySink()
|
|
|
|
{
|
|
|
|
// nil
|
|
|
|
}
|
|
|
|
|
|
|
|
public:
|
2017-04-29 01:24:00 +01:00
|
|
|
Task::Status init(QNetworkRequest & request) override
|
2016-05-28 18:54:17 +01:00
|
|
|
{
|
|
|
|
m_output->clear();
|
|
|
|
if(initAllValidators(request))
|
2017-04-29 01:24:00 +01:00
|
|
|
return Task::Status::InProgress;
|
|
|
|
return Task::Status::Failed;
|
2016-05-28 18:54:17 +01:00
|
|
|
};
|
|
|
|
|
2017-04-29 01:24:00 +01:00
|
|
|
Task::Status write(QByteArray & data) override
|
2016-05-28 18:54:17 +01:00
|
|
|
{
|
|
|
|
m_output->append(data);
|
|
|
|
if(writeAllValidators(data))
|
2017-04-29 01:24:00 +01:00
|
|
|
return Task::Status::InProgress;
|
|
|
|
return Task::Status::Failed;
|
2016-05-28 18:54:17 +01:00
|
|
|
}
|
|
|
|
|
2017-04-29 01:24:00 +01:00
|
|
|
Task::Status abort() override
|
2016-05-28 18:54:17 +01:00
|
|
|
{
|
|
|
|
m_output->clear();
|
|
|
|
failAllValidators();
|
2017-04-29 01:24:00 +01:00
|
|
|
return Task::Status::Failed;
|
2016-05-28 18:54:17 +01:00
|
|
|
}
|
|
|
|
|
2017-04-29 01:24:00 +01:00
|
|
|
Task::Status finalize(QNetworkReply &reply) override
|
2016-05-28 18:54:17 +01:00
|
|
|
{
|
|
|
|
if(finalizeAllValidators(reply))
|
2017-04-29 01:24:00 +01:00
|
|
|
return Task::Status::Finished;
|
|
|
|
return Task::Status::Failed;
|
2016-05-28 18:54:17 +01:00
|
|
|
}
|
|
|
|
|
2016-10-28 01:19:19 +01:00
|
|
|
bool hasLocalData() override
|
|
|
|
{
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
2016-05-28 18:54:17 +01:00
|
|
|
private:
|
|
|
|
QByteArray * m_output;
|
|
|
|
};
|
|
|
|
}
|