| 545 | } |
| 546 | |
| 547 | ~StreamingResponseDecoder() |
| 548 | { |
| 549 | delete response; |
| 550 | |
| 551 | if (writer.isSome()) { |
| 552 | writer->fail("Decoder is being deleted"); |
| 553 | } |
| 554 | |
| 555 | foreach (http::Response* response, responses) { |
| 556 | delete response; |
| 557 | } |
| 558 | } |
| 559 | |
| 560 | std::deque<http::Response*> decode(const char* data, size_t length) |
| 561 | { |