libutil: allow access to async stream buffers

this is easier than remembering which buffer was used during construction.

Change-Id: I64a8bdcbc0104c5a4a3330266b508cfd9297852e
This commit is contained in:
eldritch horrors
2025-08-05 19:49:11 +02:00
parent cad6118e20
commit 7e8b44d718
+10
View File
@@ -129,6 +129,11 @@ public:
KJ_DISALLOW_COPY_AND_MOVE(AsyncBufferedInputStream);
kj::Promise<Result<std::optional<size_t>>> read(void * data, size_t size) override;
IoBuffer & getBuffer()
{
return *buffer;
}
};
class AsyncOutputStream : private kj::AsyncObject
@@ -177,6 +182,11 @@ public:
kj::Promise<Result<size_t>> write(const void * src, size_t size) override;
kj::Promise<Result<void>> flush();
IoBuffer & getBuffer()
{
return *buffer;
}
};
class AsyncStream : public AsyncInputStream, public AsyncOutputStream