| 63 | } |
| 64 | |
| 65 | size_t Server::push() { |
| 66 | if (!mResponseSink) { |
| 67 | return 0; |
| 68 | } |
| 69 | |
| 70 | size_t sent = 0; |
| 71 | |
| 72 | // Push queued responses |
| 73 | while (!mOutgoingQueue.empty()) { |
| 74 | mResponseSink(mOutgoingQueue[0]); |
| 75 | mOutgoingQueue.erase(mOutgoingQueue.begin()); |
| 76 | sent++; |
| 77 | } |
| 78 | |
| 79 | return sent; |
| 80 | } |
| 81 | |
| 82 | } // namespace fl |