WritableStreamDefaultWriter
Background
A writer is used when you want to write directly to a WritableStream, rather than piping data to it from a ReadableStream. For example:
function writeArrayToStream(array, writableStream) { const writer = writableStream.getWriter(); array.forEach(chunk => writer.write(chunk).catch(() => {}));
return writer.close();
}
writeArrayToStream([1, 2, 3, 4, 5], writableStream) .then(() => console.log('All done!')) .catch(e => console.error('Error with the stream: ' + e));
Properties
desiredSizeint- The size needed to fill the stream’s internal queue, as an integer. Always returns 1, 0 (if the stream is closed), or
null(if the stream has errors).
- The size needed to fill the stream’s internal queue, as an integer. Always returns 1, 0 (if the stream is closed), or
closedPromise<void>- A promise that indicates if the writer is closed. The promise is fulfilled when the writer stream is closed and rejected if there is an error in the stream.
Methods
abort(reasonstring)Promise<void>- Aborts the stream. This method returns a promise that fulfills with a response
undefined.reasonis an optional human-readable string indicating the reason for cancellation.reasonwill be passed to the underlying sink’s abort algorithm. If this writable stream is one side of a TransformStream, then its abort algorithm causes the transform’s readable side to become errored withreason.
- Aborts the stream. This method returns a promise that fulfills with a response
close()Promise<void>- Attempts to close the writer. Remaining writes finish processing before the writer is closed. This method returns a promise fulfilled with
undefinedif the writer successfully closes and processes the remaining writes, or rejected on any error.
- Attempts to close the writer. Remaining writes finish processing before the writer is closed. This method returns a promise fulfilled with
releaseLock()voidReleases the writer’s lock on the stream. Once released, the writer is no longer active. You can call this method before all pending
write(chunk)calls are resolved. This allows you to queue awriteoperation, release the lock, and begin piping into the writable stream from another source, as shown in the example below.let writer = writable.getWriter();// Write a preamble.writer.write(new TextEncoder().encode(‘foo bar’));// While that’s still writing, pipe the rest of the body from somewhere else.writer.releaseLock();await someResponse.body.pipeTo(writable);write(chunkany)Promise<void>- Writes a chunk of data to the writer and returns a promise that resolves if the operation succeeds.