diff --git a/lix/libutil/async-io.hh b/lix/libutil/async-io.hh index 3875b50b4..7210a1ec4 100644 --- a/lix/libutil/async-io.hh +++ b/lix/libutil/async-io.hh @@ -129,6 +129,11 @@ public: KJ_DISALLOW_COPY_AND_MOVE(AsyncBufferedInputStream); kj::Promise>> read(void * data, size_t size) override; + + IoBuffer & getBuffer() + { + return *buffer; + } }; class AsyncOutputStream : private kj::AsyncObject @@ -177,6 +182,11 @@ public: kj::Promise> write(const void * src, size_t size) override; kj::Promise> flush(); + + IoBuffer & getBuffer() + { + return *buffer; + } }; class AsyncStream : public AsyncInputStream, public AsyncOutputStream