diff --git a/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.cpp b/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.cpp index ab4e2f3b3b6..4b7bf1e1469 100644 --- a/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.cpp +++ b/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.cpp @@ -15,6 +15,7 @@ #include #include #include +#include #include #include #include @@ -187,6 +188,13 @@ JS::NonnullGCPtr ReadableStreamDefaultReader::read() return JS::NonnullGCPtr { verify_cast(*promise_capability->promise()) }; } +void ReadableStreamDefaultReader::read_a_chunk(Fetch::Infrastructure::IncrementalReadLoopReadRequest& read_request) +{ + // To read a chunk from a ReadableStreamDefaultReader reader, given a read request readRequest, + // perform ! ReadableStreamDefaultReaderRead(reader, readRequest). + readable_stream_default_reader_read(*this, read_request); +} + // https://streams.spec.whatwg.org/#readablestreamdefaultreader-read-all-bytes void ReadableStreamDefaultReader::read_all_bytes(ReadLoopReadRequest::SuccessSteps success_steps, ReadLoopReadRequest::FailureSteps failure_steps) { diff --git a/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.h b/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.h index aff02716ef2..e7ca72293cf 100644 --- a/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.h +++ b/Userland/Libraries/LibWeb/Streams/ReadableStreamDefaultReader.h @@ -79,6 +79,7 @@ public: JS::NonnullGCPtr read(); + void read_a_chunk(Fetch::Infrastructure::IncrementalReadLoopReadRequest& read_request); void read_all_bytes(ReadLoopReadRequest::SuccessSteps, ReadLoopReadRequest::FailureSteps); void read_all_chunks(ReadLoopReadRequest::ChunkSteps, ReadLoopReadRequest::SuccessSteps, ReadLoopReadRequest::FailureSteps); JS::NonnullGCPtr read_all_bytes_deprecated();