| 826 | HttpOutgoingMessage::ChunkedWritableStream::ChunkedWritableStream() { setWriteQueue(queue); } |
| 827 | |
| 828 | Result HttpOutgoingMessage::ChunkedWritableStream::init(AsyncBuffersPool& buffersPool, |
| 829 | AsyncWritableStream& newDestination) |
| 830 | { |
| 831 | destination = &newDestination; |
| 832 | currentBodyBufferID = {}; |
| 833 | currentBodyCallback = {}; |
| 834 | finalChunkStarted = false; |
| 835 | finalChunkWritten = false; |
| 836 | return AsyncWritableStream::init(buffersPool); |
| 837 | } |
| 838 | |
| 839 | Result HttpOutgoingMessage::ChunkedWritableStream::asyncWrite(AsyncBufferView::ID bufferID, |
| 840 | Function<void(AsyncBufferView::ID)> cb) |
no test coverage detected