method
http2.ServerHttp2Stream.respondWithFD
Initiates a response whose data is read from the given file descriptor. No validation is performed on the given file descriptor. If an error occurs while attempting to read data using the file descriptor, the Http2Stream will be closed using an RST_STREAM frame using the standard INTERNAL_ERROR code.
When used, the Http2Stream object's Duplex interface will be closed automatically.
import http2 from 'node:http2';
import fs from 'node:fs';
const server = http2.createServer();
server.on('stream', (stream) => {
const fd = fs.openSync('/some/file', 'r');
const stat = fs.fstatSync(fd);
const headers = {
'content-length': stat.size,
'last-modified': stat.mtime.toUTCString(),
'content-type': 'text/plain; charset=utf-8',
};
stream.respondWithFD(fd, headers);
stream.on('close', () => fs.closeSync(fd));
});The optional options.statCheck function may be specified to give user code an opportunity to set additional content headers based on the fs.Stat details of the given fd. If the statCheck function is provided, the http2stream.respondWithFD() method will perform an fs.fstat() call to collect details on the provided file descriptor.
The offset and length options may be used to limit the response to a specific range subset. This can be used, for instance, to support HTTP Range requests.
The file descriptor or FileHandle is not closed when the stream is closed, so it will need to be closed manually once it is no longer needed. Using the same file descriptor concurrently for multiple streams is not supported and may result in data loss. Re-using a file descriptor after a stream has finished is supported.
When the options.waitForTrailers option is set, the 'wantTrailers' event will be emitted immediately after queuing the last chunk of payload data to be sent. The http2stream.sendTrailers() method can then be used to sent trailing header fields to the peer.
When options.waitForTrailers is set, the Http2Stream will not automatically close when the final DATA frame is transmitted. User code must call either http2stream.sendTrailers() or http2stream.close() to close the Http2Stream.
import http2 from 'node:http2';
import fs from 'node:fs';
const server = http2.createServer();
server.on('stream', (stream) => {
const fd = fs.openSync('/some/file', 'r');
const stat = fs.fstatSync(fd);
const headers = {
'content-length': stat.size,
'last-modified': stat.mtime.toUTCString(),
'content-type': 'text/plain; charset=utf-8',
};
stream.respondWithFD(fd, headers, { waitForTrailers: true });
stream.on('wantTrailers', () => {
stream.sendTrailers({ ABC: 'some value to send' });
});
stream.on('close', () => fs.closeSync(fd));
});A readable file descriptor.
Referenced types
interface FileHandle
Calls
filehandle.close()and returns a promise that fulfills when the filehandle is closed.- data: string | ArrayBufferView<ArrayBufferLike> | Iterable<unknown, any, any> | AsyncIterable<unknown, any, any>,): Promise<void>;
Alias of
filehandle.writeFile().When operating on file handles, the mode cannot be changed from what it was set to with
fsPromises.open(). Therefore, this is equivalent tofilehandle.writeFile().@returnsFulfills with
undefinedupon success. Closes the file handle after waiting for any pending operation on the handle to complete.
import { open } from 'node:fs/promises'; let filehandle; try { filehandle = await open('thefile.txt', 'r'); } finally { await filehandle?.close(); }@returnsFulfills with
undefinedupon success.Unlike the 16 KiB default
highWaterMarkfor astream.Readable, the stream returned by this method has a defaulthighWaterMarkof 64 KiB.optionscan includestartandendvalues to read a range of bytes from the file instead of the entire file. Bothstartandendare inclusive and start counting at 0, allowed values are in the [0,Number.MAX_SAFE_INTEGER] range. Ifstartis omitted orundefined,filehandle.createReadStream()reads sequentially from the current file position. Theencodingcan be any one of those accepted byBuffer.If the
FileHandlepoints to a character device that only supports blocking reads (such as keyboard or sound card), read operations do not finish until data is available. This can prevent the process from exiting and the stream from closing naturally.By default, the stream will emit a
'close'event after it has been destroyed. Set theemitCloseoption tofalseto change this behavior.import { open } from 'node:fs/promises'; const fd = await open('/dev/input/event0'); // Create a stream from some character device. const stream = fd.createReadStream(); setTimeout(() => { stream.close(); // This may not close the stream. // Artificially marking end-of-stream, as if the underlying resource had // indicated end-of-file by itself, allows the stream to close. // This does not cancel pending read operations, and if there is such an // operation, the process may still not be able to exit successfully // until it finishes. stream.push(null); stream.read(0); }, 100);If
autoCloseis false, then the file descriptor won't be closed, even if there's an error. It is the application's responsibility to close it and make sure there's no file descriptor leak. IfautoCloseis set to true (default behavior), on'error'or'end'the file descriptor will be closed automatically.An example to read the last 10 bytes of a file which is 100 bytes long:
import { open } from 'node:fs/promises'; const fd = await open('sample.txt'); fd.createReadStream({ start: 90, end: 99 });optionsmay also include astartoption to allow writing data at some position past the beginning of the file, allowed values are in the [0,Number.MAX_SAFE_INTEGER] range. Modifying a file rather than replacing it may require theflagsopenoption to be set tor+rather than the defaultr. Theencodingcan be any one of those accepted byBuffer.If
autoCloseis set to true (default behavior) on'error'or'finish'the file descriptor will be closed automatically. IfautoCloseis false, then the file descriptor won't be closed, even if there's an error. It is the application's responsibility to close it and make sure there's no file descriptor leak.By default, the stream will emit a
'close'event after it has been destroyed. Set theemitCloseoption tofalseto change this behavior.Forces all currently queued I/O operations associated with the file to the operating system's synchronized I/O completion state. Refer to the POSIX
fdatasync(2)documentation for details.Unlike
filehandle.syncthis method does not flush modified metadata.@returnsFulfills with
undefinedupon success.- pull(
Return the file contents as an async iterable using the
node:stream/iterpull model. Reads are performed inchunkSize-byte chunks (default 128 KB). If transforms are provided, they are applied viastream/iter pull().The file handle is locked while the iterable is being consumed and unlocked when iteration completes, an error occurs, or the consumer breaks.
This function is only available when the
--experimental-stream-iterflag is enabled.import { open } from 'node:fs/promises'; import { text } from 'node:stream/iter'; import { compressGzip } from 'node:zlib/iter'; const fh = await open('input.txt', 'r'); // Read as text console.log(await text(fh.pull({ autoClose: true }))); // Read 1 KB starting at byte 100 const fh2 = await open('input.txt', 'r'); console.log(await text(fh2.pull({ start: 100, limit: 1024, autoClose: true }))); // Read with compression const fh3 = await open('input.txt', 'r'); const compressed = fh3.pull(compressGzip(), { autoClose: true }); - buffer: T,offset?: null | number,length?: null | number,
Reads data from the file and stores that in the given buffer.
If the file is not modified concurrently, the end-of-file is reached when the number of bytes read is zero.
@param bufferA buffer that will be filled with the file data read.
@param offsetThe location in the buffer at which to start filling.
@param lengthThe number of bytes to read.
@param positionThe location where to begin reading data from the file. If
null, data will be read from the current file position, and the position will be updated. Ifpositionis an integer, the current file position will remain unchanged.@returnsFulfills upon success with an object with two properties:
buffer: T, - ): ReadableStream;
Returns a byte-oriented
ReadableStreamthat may be used to read the file's contents.An error will be thrown if this method is called more than once or is called after the
FileHandleis closed or closing.import { open, } from 'node:fs/promises'; const file = await open('./some/file/to/read'); for await (const chunk of file.readableWebStream()) console.log(chunk); await file.close();While the
ReadableStreamwill read the file to completion, it will not close theFileHandleautomatically. User code must still call thefileHandle.close()method. - ): Promise<NonSharedBuffer>;
Asynchronously reads the entire contents of a file.
If
optionsis a string, then it specifies theencoding.The
FileHandlehas to support reading.If one or more
filehandle.read()calls are made on a file handle and then afilehandle.readFile()call is made, the data will be read from the current position till the end of the file. It doesn't always read from the beginning of the file.@returnsFulfills upon a successful read with the contents of the file. If no encoding is specified (using
options.encoding), the data is returned as a {Buffer} object. Otherwise, the data will be a string.): Promise<string | NonSharedBuffer>;Asynchronously reads the entire contents of a file. The underlying file will not be closed automatically. The
FileHandlemust have been opened for reading. Convenience method to create a
readlineinterface and stream over the file. Seefilehandle.createReadStream()for the options.import { open } from 'node:fs/promises'; const file = await open('./some/file/to/read'); for await (const line of file.readLines()) { console.log(line); }- @param position
The offset from the beginning of the file where the data should be read from. If
positionis not anumber, the data will be read from the current position.@returnsFulfills upon success an object containing two properties:
- @returns
Fulfills with an {fs.Stats} for the file.
- len?: number): Promise<void>;
Truncates the file.
If the file was larger than
lenbytes, only the firstlenbytes will be retained in the file.The following example retains only the first four bytes of the file:
import { open } from 'node:fs/promises'; let filehandle = null; try { filehandle = await open('temp.txt', 'r+'); await filehandle.truncate(4); } finally { await filehandle?.close(); }If the file previously was shorter than
lenbytes, it is extended, and the extended part is filled with null bytes ('\0'):If
lenis negative then0will be used.@returnsFulfills with
undefinedupon success. - buffer: TBuffer,offset?: null | number,length?: null | number,position?: null | number): Promise<{ buffer: TBuffer; bytesWritten: number }>;
Write
bufferto the file.The promise is fulfilled with an object containing two properties:
It is unsafe to use
filehandle.write()multiple times on the same file without waiting for the promise to be fulfilled (or rejected). For this scenario, usefilehandle.createWriteStream().On Linux, positional writes do not work when the file is opened in append mode. The kernel ignores the position argument and always appends the data to the end of the file.
@param offsetThe start position from within
bufferwhere the data to write begins.@param lengthThe number of bytes from
bufferto write.@param positionThe offset from the beginning of the file where the data from
buffershould be written. Ifpositionis not anumber, the data will be written at the current position. See the POSIX pwrite(2) documentation for more detail.buffer: TBuffer,options?: { length: number; offset: number; position: number }): Promise<{ buffer: TBuffer; bytesWritten: number }>;data: string,position?: null | number,encoding?: null | BufferEncoding): Promise<{ buffer: string; bytesWritten: number }>; - data: string | ArrayBufferView<ArrayBufferLike> | Iterable<unknown, any, any> | AsyncIterable<unknown, any, any>,): Promise<void>;
Asynchronously writes data to a file, replacing the file if it already exists.
datacan be a string, a buffer, an AsyncIterable, or an Iterable object. The promise is fulfilled with no arguments upon success.If
optionsis a string, then it specifies theencoding.The
FileHandlehas to support writing.It is unsafe to use
filehandle.writeFile()multiple times on the same file without waiting for the promise to be fulfilled (or rejected).If one or more
filehandle.write()calls are made on a file handle and then afilehandle.writeFile()call is made, the data will be written from the current position till the end of the file. It doesn't always write from the beginning of the file. Return a
node:stream/iterwriter backed by this file handle.The writer supports both
Symbol.asyncDisposeandSymbol.dispose:await using w = fh.writer()— if the writer is still open (noend()called),asyncDisposecallsfail(). Ifend()is pending, it waits for it to complete.using w = fh.writer()— callsfail()unconditionally.
The
writeSync()andwritevSync()methods enable the try-sync fast path used bystream/iter pipeTo(). When the reader's chunk size matches the writer'schunkSize, all writes in apipeTo()pipeline complete synchronously with zero promise overhead.This function is only available when the
--experimental-stream-iterflag is enabled.import { open } from 'node:fs/promises'; import { from, pipeTo } from 'node:stream/iter'; import { compressGzip } from 'node:zlib/iter'; // Async pipeline const fh = await open('output.gz', 'w'); await pipeTo(from('Hello!'), compressGzip(), fh.writer({ autoClose: true })); // Sync pipeline with limit const src = await open('input.txt', 'r'); const dst = await open('output.txt', 'w'); const w = dst.writer({ limit: 1024 * 1024 }); // Max 1 MB await pipeTo(src.pull({ autoClose: true }), w); await w.end(); await dst.close();- buffers: TBuffers,position?: number
Write an array of ArrayBufferView s to the file.
The promise is fulfilled with an object containing a two properties:
It is unsafe to call
writev()multiple times on the same file without waiting for the promise to be fulfilled (or rejected).On Linux, positional writes don't work when the file is opened in append mode. The kernel ignores the position argument and always appends the data to the end of the file.
@param positionThe offset from the beginning of the file where the data from
buffersshould be written. Ifpositionis not anumber, the data will be written at the current position.