Baseline Widely available
Note: This feature is available in Web Workers.
The enqueue() method of the ReadableStreamDefaultController interface enqueues a given chunk in the associated stream.
chunk
The chunk to enqueue.
None (undefined).
TypeError
Thrown if enqueue() is called when the stream is not readable â because it is already closed, cancelled, or errored â or because it has been requested to close by the underlying source but it has not yet done so because there are still enqueued chunks to read.
In the following simple example, a custom ReadableStream is created using a constructor (see our Simple random stream example for the full code). The start() function generates a random string of text every second and enqueues it into the stream â see controller.enqueue(string). A cancel() function is also provided to stop the generation if ReadableStream.cancel() is called for any reason.
When a button is pressed, the generation is stopped, the stream is closed using ReadableStreamDefaultController.close(), and another function is run, which reads the data back out of the stream.
let interval;
const stream = new ReadableStream({
start(controller) {
interval = setInterval(() => {
let string = randomChars();
// Add the string to the stream
controller.enqueue(string);
// show it on the screen
let listItem = document.createElement("li");
listItem.textContent = string;
list1.appendChild(listItem);
}, 1000);
button.addEventListener("click", () => {
clearInterval(interval);
fetchStream();
controller.close();
});
},
pull(controller) {
// We don't really need a pull in this example
},
cancel() {
// This is called if the reader cancels,
// so we should stop generating strings
clearInterval(interval);
},
});
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4