httq/BodyReader.cpp at master · wille-io/httq · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
#include <httq/BodyReader.h>


BodyReader::BodyReader(httq::HttpRequest &request)
  : QObject()
  , mBuf(new QBuffer(&mBa))
{
  mBuf->open(QIODevice::WriteOnly);

  mDs = request.createDataStreamFromClient(mBuf, request.contentLength());

  connect(mDs, &QObject::destroyed,
    this, [this]()
    {
      emit signalDone();
    });

#if 0
  connect(mDs, &DataStream::signalDone,
          this, [this]()
  {
    LOG << "ds done";
  });

  connect(mDs, &DataStream::signalError,
  this, [this]()
  {
    LOG << "ds error";
  });
#endif

  connect(mDs, &httq::DataStream::signalError,
          this, &BodyReader::signalError);
}


BodyReader::~BodyReader()
{
  delete mBuf;
}


QByteArray &BodyReader::body()
{
  return mBa;
}