WritableStreamDefaultController: signal-Eigenschaft

Hinweis: Diese Funktion ist in Web Workers verfügbar.

const writingStream = new WritableStream({
 // Define the slow local sink to simulate a long operation
 write(chunk, controller) {
 return new Promise((resolve, reject) => {
 controller.signal.addEventListener("abort", () =>
 reject(controller.signal.reason),
 );
 // Do nothing but wait with the data: it is a local sink
 setTimeout(resolve, 1000); // Timeout to simulate a slow operation
 });
 },
});
// Perform the write
const writer = writingStream.getWriter();
writer.write("Lorem ipsum test data");
// Abort the write manually
await writer.abort("Manual abort!");

const endpoint = "https://www.example.com/api"; // Fake URL for example purpose
const writingStream = new WritableStream({
 async write(chunk, controller) {
 // Write to the server using the Fetch API
 const response = await fetch(endpoint, {
 signal: controller.signal, // We use the same object for both fetch and controller
 method: "POST",
 body: chunk,
 });
 await response.text();
 },
});
// Perform the write
const writer = writingStream.getWriter();
writer.write("Lorem ipsum test data");
// Abort the write manually
await writer.abort("Manual abort!");

Help improve MDN