ITranslateExpressRequest
Extends
Omit<Request,"protocol"|"param"|"unshift">
Properties
aborted
aborted:
boolean
The message.aborted property will be true if the request has
been aborted.
Since
v10.1.0
Deprecated
Since v17.0.0,v16.12.0 - Check message.destroyed from stream.Readable.
Inherited from
Omit.aborted
accepted
accepted:
MediaType[]
Return an array of Accepted media types ordered from highest quality to lowest.
Inherited from
Omit.accepted
app
app:
Application<Record<string,any>>
Inherited from
Omit.app
baseUrl
baseUrl:
string
Inherited from
Omit.baseUrl
body
body:
any
Inherited from
Omit.body
closed
readonlyclosed:boolean
Is true after 'close' has been emitted.
Since
v18.0.0
Inherited from
Omit.closed
complete
complete:
boolean
The message.complete property will be true if a complete HTTP message has
been received and successfully parsed.
This property is particularly useful as a means of determining if a client or server fully transmitted a message before a connection was terminated:
const req = http.request({
host: '127.0.0.1',
port: 8080,
method: 'POST',
}, (res) => {
res.resume();
res.on('end', () => {
if (!res.complete)
console.error(
'The connection was terminated while the message was still being sent');
});
});
Since
v0.3.0
Inherited from
Omit.complete
connection
connection:
Socket
Alias for message.socket.
Since
v0.1.90
Deprecated
Since v16.0.0 - Use socket.
Inherited from
Omit.connection
cookies
cookies:
any
Inherited from
Omit.cookies
destroyed
destroyed:
boolean
Is true after readable.destroy() has been called.
Since
v8.0.0
Inherited from
Omit.destroyed
errored
readonlyerrored:Error
Returns error if the stream has been destroyed with an error.
Since
v18.0.0
Inherited from
Omit.errored
fresh
readonlyfresh:boolean
Check if the request is fresh, aka Last-Modified and/or the ETag still match.
Inherited from
Omit.fresh
headers
headers:
IncomingHttpHeaders
The request/response headers object.
Key-value pairs of header names and values. Header names are lower-cased.
// Prints something like:
//
// { 'user-agent': 'curl/7.22.0',
// host: '127.0.0.1:8000',
// accept: '*' }
console.log(request.headers);
Duplicates in raw headers are handled in the following ways, depending on the header name:
- Duplicates of
age,authorization,content-length,content-type,etag,expires,from,host,if-modified-since,if-unmodified-since,last-modified,location,max-forwards,proxy-authorization,referer,retry-after,server, oruser-agentare discarded. To allow duplicate values of the headers listed above to be joined, use the optionjoinDuplicateHeadersin request and createServer. See RFC 9110 Section 5.3 for more information. set-cookieis always an array. Duplicates are added to the array.- For duplicate
cookieheaders, the values are joined together with;. - For all other headers, the values are joined together with
,.
Since
v0.1.5
Inherited from
Omit.headers
headersDistinct
headersDistinct:
Dict<string[]>
Similar to message.headers, but there is no join logic and the values are
always arrays of strings, even for headers received just once.
// Prints something like:
//
// { 'user-agent': ['curl/7.22.0'],
// host: ['127.0.0.1:8000'],
// accept: ['*'] }
console.log(request.headersDistinct);
Since
v18.3.0, v16.17.0
Inherited from
Omit.headersDistinct
host
readonlyhost:string
Deprecated
Use hostname instead.
Inherited from
Omit.host
hostname
readonlyhostname:string
Parse the "Host" header field hostname.
Inherited from
Omit.hostname
httpVersion
httpVersion:
string
In case of server request, the HTTP version sent by the client. In the case of
client response, the HTTP version of the connected-to server.
Probably either '1.1' or '1.0'.
Also message.httpVersionMajor is the first integer and message.httpVersionMinor is the second.
Since
v0.1.1
Inherited from
Omit.httpVersion
httpVersionMajor
httpVersionMajor:
number
Inherited from
Omit.httpVersionMajor
httpVersionMinor
httpVersionMinor:
number
Inherited from
Omit.httpVersionMinor
ip
readonlyip:string
Return the remote address, or when
"trust proxy" is true return
the upstream addr.
Value may be undefined if the req.socket is destroyed
(for example, if the client disconnected).
Inherited from
Omit.ip
ips
readonlyips:string[]
When "trust proxy" is true, parse
the "X-Forwarded-For" ip address list.
For example if the value were "client, proxy1, proxy2"
you would receive the array ["client", "proxy1", "proxy2"]
where "proxy2" is the furthest down-stream.
Inherited from
Omit.ips
method
method:
string
Inherited from
Omit.method
next?
optionalnext:NextFunction
Inherited from
Omit.next
originalUrl
originalUrl:
string
Inherited from
Omit.originalUrl
params
params:
ParamsDictionary
Inherited from
Omit.params
path
readonlypath:string
Short-hand for url.parse(req.url).pathname.
Inherited from
Omit.path
query
query:
ParsedQs
Inherited from
Omit.query
rawHeaders
rawHeaders:
string[]
The raw request/response headers list exactly as they were received.
The keys and values are in the same list. It is not a list of tuples. So, the even-numbered offsets are key values, and the odd-numbered offsets are the associated values.
Header names are not lowercased, and duplicates are not merged.
// Prints something like:
//
// [ 'user-agent',
// 'this is invalid because there can be only one',
// 'User-Agent',
// 'curl/7.22.0',
// 'Host',
// '127.0.0.1:8000',
// 'ACCEPT',
// '*' ]
console.log(request.rawHeaders);
Since
v0.11.6
Inherited from
Omit.rawHeaders
rawTrailers
rawTrailers:
string[]
The raw request/response trailer keys and values exactly as they were
received. Only populated at the 'end' event.
Since
v0.11.6
Inherited from
Omit.rawTrailers
readable
readable:
boolean
Is true if it is safe to call read, which means
the stream has not been destroyed or emitted 'error' or 'end'.
Since
v11.4.0
Inherited from
Omit.readable
readableAborted
Experimental
readonlyreadableAborted:boolean
Returns whether the stream was destroyed or errored before emitting 'end'.
Since
v16.8.0
Inherited from
Omit.readableAborted
readableDidRead
Experimental
readonlyreadableDidRead:boolean
Returns whether 'data' has been emitted.
Since
v16.7.0, v14.18.0
Inherited from
Omit.readableDidRead
readableEncoding
readonlyreadableEncoding:BufferEncoding
Getter for the property encoding of a given Readable stream. The encoding property can be set using the setEncoding method.
Since
v12.7.0
Inherited from
Omit.readableEncoding
readableEnded
readonlyreadableEnded:boolean
Becomes true when 'end' event is emitted.
Since
v12.9.0
Inherited from
Omit.readableEnded
readableFlowing
readonlyreadableFlowing:boolean
This property reflects the current state of a Readable stream as described
in the Three states section.
Since
v9.4.0
Inherited from
Omit.readableFlowing
readableHighWaterMark
readonlyreadableHighWaterMark:number
Returns the value of highWaterMark passed when creating this Readable.
Since
v9.3.0
Inherited from
Omit.readableHighWaterMark
readableLength
readonlyreadableLength:number
This property contains the number of bytes (or objects) in the queue
ready to be read. The value provides introspection data regarding
the status of the highWaterMark.
Since
v9.4.0
Inherited from
Omit.readableLength
readableObjectMode
readonlyreadableObjectMode:boolean
Getter for the property objectMode of a given Readable stream.
Since
v12.3.0
Inherited from
Omit.readableObjectMode
res?
optionalres:Response<any,Record<string,any>,number>
After middleware.init executed, Request will contain res and next properties See: express/lib/middleware/init.js
Inherited from
Omit.res
route
route:
any
Inherited from
Omit.route
secure
readonlysecure:boolean
Short-hand for:
req.protocol == 'https'
Inherited from
Omit.secure
signedCookies
signedCookies:
any
Inherited from
Omit.signedCookies
socket
socket:
Socket
The net.Socket object associated with the connection.
With HTTPS support, use request.socket.getPeerCertificate() to obtain the
client's authentication details.
This property is guaranteed to be an instance of the net.Socket class,
a subclass of stream.Duplex, unless the user specified a socket
type other than net.Socket or internally nulled.
Since
v0.3.0
Inherited from
Omit.socket
stale
readonlystale:boolean
Check if the request is stale, aka "Last-Modified" and / or the "ETag" for the resource has changed.
Inherited from
Omit.stale
statusCode?
optionalstatusCode:number
Only valid for response obtained from ClientRequest.
The 3-digit HTTP response status code. E.G. 404.
Since
v0.1.1
Inherited from
Omit.statusCode
statusMessage?
optionalstatusMessage:string
Only valid for response obtained from ClientRequest.
The HTTP response status message (reason phrase). E.G. OK or Internal Server Error.
Since
v0.11.10
Inherited from
Omit.statusMessage
subdomains
readonlysubdomains:string[]
Return subdomains as an array.
Subdomains are the dot-separated parts of the host before the main domain of the app. By default, the domain of the app is assumed to be the last two parts of the host. This can be changed by setting "subdomain offset".
For example, if the domain is "tobi.ferrets.example.com":
If "subdomain offset" is not set, req.subdomains is ["ferrets", "tobi"].
If "subdomain offset" is 3, req.subdomains is ["tobi"].
Inherited from
Omit.subdomains
tr
trailers
trailers:
Dict<string>
The request/response trailers object. Only populated at the 'end' event.
Since
v0.3.0
Inherited from
Omit.trailers
trailersDistinct
trailersDistinct:
Dict<string[]>
Similar to message.trailers, but there is no join logic and the values are
always arrays of strings, even for headers received just once.
Only populated at the 'end' event.
Since
v18.3.0, v16.17.0
Inherited from
Omit.trailersDistinct
url
url:
string
Inherited from
Omit.url
xhr
readonlyxhr:boolean
Check if the request was an XMLHttpRequest.
Inherited from
Omit.xhr
Methods
[asyncDispose]()
[asyncDispose]():
Promise<void>
Calls readable.destroy() with an AbortError and returns a promise that fulfills when the stream is finished.
Returns
Promise<void>
Inherited from
Omit.[asyncDispose]
Since
v20.4.0
[asyncIterator]()
[asyncIterator]():
AsyncIterableIterator<any>
Returns
AsyncIterableIterator<any>
Inherited from
Omit.[asyncIterator]
[captureRejectionSymbol]()?
optional[captureRejectionSymbol]<K>(error,event, ...args):void
Type parameters
| Type parameter |
|---|
K |
Parameters
| Parameter | Type |
|---|---|
error | Error |
event | string | symbol |
...args | AnyRest |
Returns
void
Inherited from
Omit.[captureRejectionSymbol]
_construct()?
optional_construct(callback):void
Parameters
| Parameter | Type |
|---|---|
callback | (error?) => void |
Returns
void
Inherited from
Omit._construct
_destroy()
_destroy(
error,callback):void
Parameters
| Parameter | Type |
|---|---|
error | Error |
callback | (error?) => void |
Returns
void
Inherited from
Omit._destroy
_read()
_read(
size):void
Parameters
| Parameter | Type |
|---|---|
size | number |
Returns
void
Inherited from
Omit._read
accepts()
accepts()
accepts():
string[]
Check if the given type(s) is acceptable, returning
the best match when true, otherwise undefined, in which
case you should respond with 406 "Not Acceptable".
The type value may be a single mime type string
such as "application/json", the extension name
such as "json", a comma-delimted list such as "json, html, text/plain",
or an array ["json", "html", "text/plain"]. When a list
or array is given the best match, if any is returned.
Examples:
// Accept: text/html req.accepts('html'); // => "html"
// Accept: text/*, application/json req.accepts('html'); // => "html" req.accepts('text/html'); // => "text/html" req.accepts('json, text'); // => "json" req.accepts('application/json'); // => "application/json"
// Accept: text/*, application/json req.accepts('image/png'); req.accepts('png'); // => false
// Accept: text/*;q=.5, application/json req.accepts(['html', 'json']); req.accepts('html, json'); // => "json"
Returns
string[]
Inherited from
Omit.accepts
accepts(type)
accepts(
type):string|false
Parameters
| Parameter | Type |
|---|---|
type | string |
Returns
string | false
Inherited from
Omit.accepts
accepts(type)
accepts(
type):string|false
Parameters
| Parameter | Type |
|---|---|
type | string[] |
Returns
string | false
Inherited from
Omit.accepts
accepts(type)
accepts(...
type):string|false
Parameters
| Parameter | Type |
|---|---|
...type | string[] |
Returns
string | false
Inherited from
Omit.accepts
acceptsCharsets()
acceptsCharsets()
acceptsCharsets():
string[]
Returns the first accepted charset of the specified character sets, based on the request's Accept-Charset HTTP header field. If none of the specified charsets is accepted, returns false.
For more information, or if you have issues or concerns, see accepts.
Returns
string[]
Inherited from
Omit.acceptsCharsets
acceptsCharsets(charset)
acceptsCharsets(
charset):string|false
Parameters
| Parameter | Type |
|---|---|
charset | string |
Returns
string | false
Inherited from
Omit.acceptsCharsets
acceptsCharsets(charset)
acceptsCharsets(
charset):string|false
Parameters
| Parameter | Type |
|---|---|
charset | string[] |
Returns
string | false
Inherited from
Omit.acceptsCharsets
acceptsCharsets(charset)
acceptsCharsets(...
charset):string|false
Parameters
| Parameter | Type |
|---|---|
...charset | string[] |
Returns
string | false
Inherited from
Omit.acceptsCharsets
acceptsEncodings()
acceptsEncodings()
acceptsEncodings():
string[]
Returns the first accepted encoding of the specified encodings, based on the request's Accept-Encoding HTTP header field. If none of the specified encodings is accepted, returns false.
For more information, or if you have issues or concerns, see accepts.
Returns
string[]
Inherited from
Omit.acceptsEncodings
acceptsEncodings(encoding)
acceptsEncodings(
encoding):string|false
Parameters
| Parameter | Type |
|---|---|
encoding | string |
Returns
string | false
Inherited from
Omit.acceptsEncodings
acceptsEncodings(encoding)
acceptsEncodings(
encoding):string|false
Parameters
| Parameter | Type |
|---|---|
encoding | string[] |
Returns
string | false
Inherited from
Omit.acceptsEncodings
acceptsEncodings(encoding)
acceptsEncodings(...
encoding):string|false
Parameters
| Parameter | Type |
|---|---|
...encoding | string[] |
Returns
string | false
Inherited from
Omit.acceptsEncodings
acceptsLanguages()
acceptsLanguages()
acceptsLanguages():
string[]
Returns the first accepted language of the specified languages, based on the request's Accept-Language HTTP header field. If none of the specified languages is accepted, returns false.
For more information, or if you have issues or concerns, see accepts.
Returns
string[]
Inherited from
Omit.acceptsLanguages
acceptsLanguages(lang)
acceptsLanguages(
lang):string|false
Parameters
| Parameter | Type |
|---|---|
lang | string |
Returns
string | false
Inherited from
Omit.acceptsLanguages
acceptsLanguages(lang)
acceptsLanguages(
lang):string|false
Parameters
| Parameter | Type |
|---|---|
lang | string[] |
Returns
string | false
Inherited from
Omit.acceptsLanguages
acceptsLanguages(lang)
acceptsLanguages(...
lang):string|false
Parameters
| Parameter | Type |
|---|---|
...lang | string[] |
Returns
string | false
Inherited from
Omit.acceptsLanguages
addListener()
addListener(event, listener)
addListener(
event,listener):this
Event emitter The defined events on documents including:
- close
- data
- end
- error
- pause
- readable
- resume
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.addListener
addListener(event, listener)
addListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.addListener
asIndexedPairs()
asIndexedPairs(
options?):Readable
This method returns a new stream with chunks of the underlying stream paired with a counter
in the form [index, chunk]. The first index value is 0 and it increases by 1 for each chunk produced.
Parameters
| Parameter | Type |
|---|---|
options? | Pick<ArrayOptions, "signal"> |
Returns
Readable
a stream of indexed pairs.
Inherited from
Omit.asIndexedPairs
Since
v17.5.0
compose()
compose<
T>(stream,options?):T
Type parameters
| Type parameter |
|---|
T extends ReadableStream |
Parameters
| Parameter | Type |
|---|---|
stream | ComposeFnParam | T | Iterable<T> | AsyncIterable<T> |
options? | object |
options.signal? | AbortSignal |
Returns
T
Inherited from
Omit.compose
destroy()
destroy(
error?):this
Calls destroy() on the socket that received the IncomingMessage. If error is provided, an 'error' event is emitted on the socket and error is passed
as an argument to any listeners on the event.
Parameters
| Parameter | Type |
|---|---|
error? | Error |
Returns
this
Inherited from
Omit.destroy
Since
v0.3.0
drop()
drop(
limit,options?):Readable
This method returns a new stream with the first limit chunks dropped from the start.
Parameters
| Parameter | Type | Description |
|---|---|---|
limit | number | the number of chunks to drop from the readable. |
options? | Pick<ArrayOptions, "signal"> | - |
Returns
Readable
a stream with limit chunks dropped from the start.
Inherited from
Omit.drop
Since
v17.5.0
emit()
emit(event)
emit(
event):boolean
Parameters
| Parameter | Type |
|---|---|
event | "close" |
Returns
boolean
Inherited from
Omit.emit
emit(event, chunk)
emit(
event,chunk):boolean
Parameters
| Parameter | Type |
|---|---|
event | "data" |
chunk | any |
Returns
boolean
Inherited from
Omit.emit
emit(event)
emit(
event):boolean
Parameters
| Parameter | Type |
|---|---|
event | "end" |
Returns
boolean
Inherited from
Omit.emit
emit(event, err)
emit(
event,err):boolean
Parameters
| Parameter | Type |
|---|---|
event | "error" |
err | Error |
Returns
boolean
Inherited from
Omit.emit
emit(event)
emit(
event):boolean
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
Returns
boolean
Inherited from
Omit.emit
emit(event)
emit(
event):boolean
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
Returns
boolean
Inherited from
Omit.emit
emit(event)
emit(
event):boolean
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
Returns
boolean
Inherited from
Omit.emit
emit(event, args)
emit(
event, ...args):boolean
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
...args | any[] |
Returns
boolean
Inherited from
Omit.emit
eventNames()
eventNames(): (
string|symbol)[]
Returns an array listing the events for which the emitter has registered
listeners. The values in the array are strings or Symbols.
import { EventEmitter } from 'node:events';
const myEE = new EventEmitter();
myEE.on('foo', () => {});
myEE.on('bar', () => {});
const sym = Symbol('symbol');
myEE.on(sym, () => {});
console.log(myEE.eventNames());
// Prints: [ 'foo', 'bar', Symbol(symbol) ]
Returns
(string | symbol)[]
Inherited from
Omit.eventNames
Since
v6.0.0
every()
every(
fn,options?):Promise<boolean>
This method is similar to Array.prototype.every and calls fn on each chunk in the stream
to check if all awaited return values are truthy value for fn. Once an fn call on a chunk
awaited return value is falsy, the stream is destroyed and the promise is fulfilled with false.
If all of the fn calls on the chunks return a truthy value, the promise is fulfilled with true.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => boolean | Promise<boolean> | a function to call on each chunk of the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Promise<boolean>
a promise evaluating to true if fn returned a truthy value for every one of the chunks.
Inherited from
Omit.every
Since
v17.5.0
filter()
filter(
fn,options?):Readable
This method allows filtering the stream. For each chunk in the stream the fn function will be called
and if it returns a truthy value, the chunk will be passed to the result stream.
If the fn function returns a promise - that promise will be awaited.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => boolean | Promise<boolean> | a function to filter chunks from the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Readable
a stream filtered with the predicate fn.
Inherited from
Omit.filter
Since
v17.4.0, v16.14.0
find()
find(fn, options)
find<
T>(fn,options?):Promise<T>
This method is similar to Array.prototype.find and calls fn on each chunk in the stream
to find a chunk with a truthy value for fn. Once an fn call's awaited return value is truthy,
the stream is destroyed and the promise is fulfilled with value for which fn returned a truthy value.
If all of the fn calls on the chunks return a falsy value, the promise is fulfilled with undefined.
Type parameters
| Type parameter |
|---|
T |
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => data is T | a function to call on each chunk of the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Promise<T>
a promise evaluating to the first chunk for which fn evaluated with a truthy value,
or undefined if no element was found.
Inherited from
Omit.find
Since
v17.5.0
find(fn, options)
find(
fn,options?):Promise<any>
Parameters
| Parameter | Type |
|---|---|
fn | (data, options?) => boolean | Promise<boolean> |
options? | ArrayOptions |
Returns
Promise<any>
Inherited from
Omit.find
flatMap()
flatMap(
fn,options?):Readable
This method returns a new stream by applying the given callback to each chunk of the stream and then flattening the result.
It is possible to return a stream or another iterable or async iterable from fn and the result streams will be merged (flattened) into the returned stream.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => any | a function to map over every chunk in the stream. May be async. May be a stream or generator. |
options? | ArrayOptions | - |
Returns
Readable
a stream flat-mapped with the function fn.
Inherited from
Omit.flatMap
Since
v17.5.0
forEach()
forEach(
fn,options?):Promise<void>
This method allows iterating a stream. For each chunk in the stream the fn function will be called.
If the fn function returns a promise - that promise will be awaited.
This method is different from for await...of loops in that it can optionally process chunks concurrently.
In addition, a forEach iteration can only be stopped by having passed a signal option
and aborting the related AbortController while for await...of can be stopped with break or return.
In either case the stream will be destroyed.
This method is different from listening to the 'data' event in that it uses the readable event
in the underlying machinary and can limit the number of concurrent fn calls.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => void | Promise<void> | a function to call on each chunk of the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Promise<void>
a promise for when the stream has finished.
Inherited from
Omit.forEach
Since
v17.5.0
get()
get(name)
get(
name):string[]
Return request header.
The Referrer header field is special-cased,
both Referrer and Referer are interchangeable.
Examples:
req.get('Content-Type'); // => "text/plain"
req.get('content-type'); // => "text/plain"
req.get('Something'); // => undefined
Aliased as req.header().
Parameters
| Parameter | Type |
|---|---|
name | "set-cookie" |
Returns
string[]
Inherited from
Omit.get
get(name)
get(
name):string
Parameters
| Parameter | Type |
|---|---|
name | string |
Returns
string
Inherited from
Omit.get
getMaxListeners()
getMaxListeners():
number
Returns the current max listener value for the EventEmitter which is either
set by emitter.setMaxListeners(n) or defaults to defaultMaxListeners.
Returns
number
Inherited from
Omit.getMaxListeners
Since
v1.0.0
header()
header(name)
header(
name):string[]
Parameters
| Parameter | Type |
|---|---|
name | "set-cookie" |
Returns
string[]
Inherited from
Omit.header
header(name)
header(
name):string
Parameters
| Parameter | Type |
|---|---|
name | string |
Returns
string
Inherited from
Omit.header
is()
is(
type):string|false
Check if the incoming request contains the "Content-Type"
header field, and it contains the give mime type.
Examples:
// With Content-Type: text/html; charset=utf-8 req.is('html'); req.is('text/html'); req.is('text/*'); // => true
// When Content-Type is application/json req.is('json'); req.is('application/json'); req.is('application/*'); // => true
req.is('html'); // => false
Parameters
| Parameter | Type |
|---|---|
type | string | string[] |
Returns
string | false
Inherited from
Omit.is
isPaused()
isPaused():
boolean
The readable.isPaused() method returns the current operating state of the Readable.
This is used primarily by the mechanism that underlies the readable.pipe() method.
In most typical cases, there will be no reason to use this method directly.
const readable = new stream.Readable();
readable.isPaused(); // === false
readable.pause();
readable.isPaused(); // === true
readable.resume();
readable.isPaused(); // === false
Returns
boolean
Inherited from
Omit.isPaused
Since
v0.11.14
iterator()
iterator(
options?):AsyncIterableIterator<any>
The iterator created by this method gives users the option to cancel the destruction
of the stream if the for await...of loop is exited by return, break, or throw,
or if the iterator should destroy the stream if the stream emitted an error during iteration.
Parameters
| Parameter | Type | Description |
|---|---|---|
options? | object | - |
options.destroyOnReturn? | boolean | When set to Default: |
Returns
AsyncIterableIterator<any>
Inherited from
Omit.iterator
Since
v16.3.0
listenerCount()
listenerCount<
K>(eventName,listener?):number
Returns the number of listeners listening for the event named eventName.
If listener is provided, it will return how many times the listener is found
in the list of the listeners of the event.
Type parameters
| Type parameter |
|---|
K |
Parameters
| Parameter | Type | Description |
|---|---|---|
eventName | string | symbol | The name of the event being listened for |
listener? | Function | The event handler function |
Returns
number
Inherited from
Omit.listenerCount
Since
v3.2.0
listeners()
listeners<
K>(eventName):Function[]
Returns a copy of the array of listeners for the event named eventName.
server.on('connection', (stream) => {
console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection')));
// Prints: [ [Function] ]
Type parameters
| Type parameter |
|---|
K |
Parameters
| Parameter | Type |
|---|---|
eventName | string | symbol |
Returns
Function[]
Inherited from
Omit.listeners
Since
v0.1.26
map()
map(
fn,options?):Readable
This method allows mapping over the stream. The fn function will be called for every chunk in the stream.
If the fn function returns a promise - that promise will be awaited before being passed to the result stream.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => any | a function to map over every chunk in the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Readable
a stream mapped with the function fn.
Inherited from
Omit.map
Since
v17.4.0, v16.14.0
off()
off<
K>(eventName,listener):this
Alias for emitter.removeListener().
Type parameters
| Type parameter |
|---|
K |
Parameters
| Parameter | Type |
|---|---|
eventName | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.off
Since
v10.0.0
on()
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.on
on(event, listener)
on(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.on
once()
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.once
once(event, listener)
once(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.once
pause()
pause():
this
The readable.pause() method will cause a stream in flowing mode to stop
emitting 'data' events, switching out of flowing mode. Any data that
becomes available will remain in the internal buffer.
const readable = getReadableStreamSomehow();
readable.on('data', (chunk) => {
console.log(`Received ${chunk.length} bytes of data.`);
readable.pause();
console.log('There will be no additional data for 1 second.');
setTimeout(() => {
console.log('Now data will start flowing again.');
readable.resume();
}, 1000);
});
The readable.pause() method has no effect if there is a 'readable' event listener.
Returns
this
Inherited from
Omit.pause
Since
v0.9.4
pipe()
pipe<
T>(destination,options?):T
Type parameters
| Type parameter |
|---|
T extends WritableStream |
Parameters
| Parameter | Type |
|---|---|
destination | T |
options? | object |
options.end? | boolean |
Returns
T
Inherited from
Omit.pipe
prependListener()
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.prependListener
prependListener(event, listener)
prependListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.prependListener
prependOnceListener()
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.prependOnceListener
prependOnceListener(event, listener)
prependOnceListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.prependOnceListener
push()
push(
chunk,encoding?):boolean
Parameters
| Parameter | Type |
|---|---|
chunk | any |
encoding? | BufferEncoding |
Returns
boolean
Inherited from
Omit.push
range()
range(
size,options?):Ranges|Result
Parse Range header field, capping to the given size.
Unspecified ranges such as "0-" require knowledge of your resource length. In
the case of a byte range this is of course the total number of bytes.
If the Range header field is not given undefined is returned.
If the Range header field is given, return value is a result of range-parser.
See more ./types/range-parser/index.d.ts
NOTE: remember that ranges are inclusive, so for example "Range: users=0-3" should respond with 4 users when available, not 3.
Parameters
| Parameter | Type |
|---|---|
size | number |
options? | Options |
Returns
Ranges | Result
Inherited from
Omit.range
rawListeners()
rawListeners<
K>(eventName):Function[]
Returns a copy of the array of listeners for the event named eventName,
including any wrappers (such as those created by .once()).
import { EventEmitter } from 'node:events';
const emitter = new EventEmitter();
emitter.once('log', () => console.log('log once'));
// Returns a new Array with a function `onceWrapper` which has a property
// `listener` which contains the original listener bound above
const listeners = emitter.rawListeners('log');
const logFnWrapper = listeners[0];
// Logs "log once" to the console and does not unbind the `once` event
logFnWrapper.listener();
// Logs "log once" to the console and removes the listener
logFnWrapper();
emitter.on('log', () => console.log('log persistently'));
// Will return a new Array with a single function bound by `.on()` above
const newListeners = emitter.rawListeners('log');
// Logs "log persistently" twice
newListeners[0]();
emitter.emit('log');
Type parameters
| Type parameter |
|---|
K |
Parameters
| Parameter | Type |
|---|---|
eventName | string | symbol |
Returns
Function[]
Inherited from
Omit.rawListeners
Since
v9.4.0
read()
read(
size?):any
The readable.read() method reads data out of the internal buffer and
returns it. If no data is available to be read, null is returned. By default,
the data is returned as a Buffer object unless an encoding has been
specified using the readable.setEncoding() method or the stream is operating
in object mode.
The optional size argument specifies a specific number of bytes to read. If
size bytes are not available to be read, null will be returned unless the
stream has ended, in which case all of the data remaining in the internal buffer
will be returned.
If the size argument is not specified, all of the data contained in the
internal buffer will be returned.
The size argument must be less than or equal to 1 GiB.
The readable.read() method should only be called on Readable streams
operating in paused mode. In flowing mode, readable.read() is called
automatically until the internal buffer is fully drained.
const readable = getReadableStreamSomehow();
// 'readable' may be triggered multiple times as data is buffered in
readable.on('readable', () => {
let chunk;
console.log('Stream is readable (new data received in buffer)');
// Use a loop to make sure we read all currently available data
while (null !== (chunk = readable.read())) {
console.log(`Read ${chunk.length} bytes of data...`);
}
});
// 'end' will be triggered once when there is no more data available
readable.on('end', () => {
console.log('Reached end of stream.');
});
Each call to readable.read() returns a chunk of data, or null. The chunks
are not concatenated. A while loop is necessary to consume all data
currently in the buffer. When reading a large file .read() may return null,
having consumed all buffered content so far, but there is still more data to
come not yet buffered. In this case a new 'readable' event will be emitted
when there is more data in the buffer. Finally the 'end' event will be
emitted when there is no more data to come.
Therefore to read a file's whole contents from a readable, it is necessary
to collect chunks across multiple 'readable' events:
const chunks = [];
readable.on('readable', () => {
let chunk;
while (null !== (chunk = readable.read())) {
chunks.push(chunk);
}
});
readable.on('end', () => {
const content = chunks.join('');
});
A Readable stream in object mode will always return a single item from
a call to readable.read(size), regardless of the value of the size argument.
If the readable.read() method returns a chunk of data, a 'data' event will
also be emitted.
Calling read after the 'end' event has
been emitted will return null. No runtime error will be raised.
Parameters
| Parameter | Type | Description |
|---|---|---|
size? | number | Optional argument to specify how much data to read. |
Returns
any
Inherited from
Omit.read
Since
v0.9.4
reduce()
reduce(fn, initial, options)
reduce<
T>(fn,initial?,options?):Promise<T>
This method calls fn on each chunk of the stream in order, passing it the result from the calculation on the previous element. It returns a promise for the final value of the reduction.
If no initial value is supplied the first chunk of the stream is used as the initial value.
If the stream is empty, the promise is rejected with a TypeError with the ERR_INVALID_ARGS code property.
The reducer function iterates the stream element-by-element which means that there is no concurrency parameter
or parallelism. To perform a reduce concurrently, you can extract the async function to readable.map method.
Type parameters
| Type parameter | Value |
|---|---|
T | any |
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (previous, data, options?) => T | a reducer function to call over every chunk in the stream. Async or not. |
initial? | undefined | the initial value to use in the reduction. |
options? | Pick<ArrayOptions, "signal"> | - |
Returns
Promise<T>
a promise for the final value of the reduction.
Inherited from
Omit.reduce
Since
v17.5.0
reduce(fn, initial, options)
reduce<
T>(fn,initial,options?):Promise<T>
Type parameters
| Type parameter | Value |
|---|---|
T | any |
Parameters
| Parameter | Type |
|---|---|
fn | (previous, data, options?) => T |
initial | T |
options? | Pick<ArrayOptions, "signal"> |
Returns
Promise<T>
Inherited from
Omit.reduce
removeAllListeners()
removeAllListeners(
eventName?):this
Removes all listeners, or those of the specified eventName.
It is bad practice to remove listeners added elsewhere in the code,
particularly when the EventEmitter instance was created by some other
component or module (e.g. sockets or file streams).
Returns a reference to the EventEmitter, so that calls can be chained.
Parameters
| Parameter | Type |
|---|---|
eventName? | string | symbol |
Returns
this
Inherited from
Omit.removeAllListeners
Since
v0.1.26
removeListener()
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "close" |
listener | () => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "data" |
listener | (chunk) => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "end" |
listener | () => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "error" |
listener | (err) => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "pause" |
listener | () => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "readable" |
listener | () => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | "resume" |
listener | () => void |
Returns
this
Inherited from
Omit.removeListener
removeListener(event, listener)
removeListener(
event,listener):this
Parameters
| Parameter | Type |
|---|---|
event | string | symbol |
listener | (...args) => void |
Returns
this
Inherited from
Omit.removeListener
resume()
resume():
this
The readable.resume() method causes an explicitly paused Readable stream to
resume emitting 'data' events, switching the stream into flowing mode.
The readable.resume() method can be used to fully consume the data from a
stream without actually processing any of that data:
getReadableStreamSomehow()
.resume()
.on('end', () => {
console.log('Reached the end, but did not read anything.');
});
The readable.resume() method has no effect if there is a 'readable' event listener.
Returns
this
Inherited from
Omit.resume
Since
v0.9.4
setEncoding()
setEncoding(
encoding):this
The readable.setEncoding() method sets the character encoding for
data read from the Readable stream.
By default, no encoding is assigned and stream data will be returned as Buffer objects. Setting an encoding causes the stream data
to be returned as strings of the specified encoding rather than as Buffer objects. For instance, calling readable.setEncoding('utf8') will cause the
output data to be interpreted as UTF-8 data, and passed as strings. Calling readable.setEncoding('hex') will cause the data to be encoded in hexadecimal
string format.
The Readable stream will properly handle multi-byte characters delivered
through the stream that would otherwise become improperly decoded if simply
pulled from the stream as Buffer objects.
const readable = getReadableStreamSomehow();
readable.setEncoding('utf8');
readable.on('data', (chunk) => {
assert.equal(typeof chunk, 'string');
console.log('Got %d characters of string data:', chunk.length);
});
Parameters
| Parameter | Type | Description |
|---|---|---|
encoding | BufferEncoding | The encoding to use. |
Returns
this
Inherited from
Omit.setEncoding
Since
v0.9.4
setMaxListeners()
setMaxListeners(
n):this
By default EventEmitters will print a warning if more than 10 listeners are
added for a particular event. This is a useful default that helps finding
memory leaks. The emitter.setMaxListeners() method allows the limit to be
modified for this specific EventEmitter instance. The value can be set to Infinity (or 0) to indicate an unlimited number of listeners.
Returns a reference to the EventEmitter, so that calls can be chained.
Parameters
| Parameter | Type |
|---|---|
n | number |
Returns
this
Inherited from
Omit.setMaxListeners
Since
v0.3.5
setTimeout()
setTimeout(
msecs,callback?):this
Calls message.socket.setTimeout(msecs, callback).
Parameters
| Parameter | Type |
|---|---|
msecs | number |
callback? | () => void |
Returns
this
Inherited from
Omit.setTimeout
Since
v0.5.9
some()
some(
fn,options?):Promise<boolean>
This method is similar to Array.prototype.some and calls fn on each chunk in the stream
until the awaited return value is true (or any truthy value). Once an fn call on a chunk
awaited return value is truthy, the stream is destroyed and the promise is fulfilled with true.
If none of the fn calls on the chunks return a truthy value, the promise is fulfilled with false.
Parameters
| Parameter | Type | Description |
|---|---|---|
fn | (data, options?) => boolean | Promise<boolean> | a function to call on each chunk of the stream. Async or not. |
options? | ArrayOptions | - |
Returns
Promise<boolean>
a promise evaluating to true if fn returned a truthy value for at least one of the chunks.
Inherited from
Omit.some
Since
v17.5.0
take()
take(
limit,options?):Readable
This method returns a new stream with the first limit chunks.
Parameters
| Parameter | Type | Description |
|---|---|---|
limit | number | the number of chunks to take from the readable. |
options? | Pick<ArrayOptions, "signal"> | - |
Returns
Readable
a stream with limit chunks taken.
Inherited from
Omit.take
Since
v17.5.0
toArray()
toArray(
options?):Promise<any[]>
This method allows easily obtaining the contents of a stream.
As this method reads the entire stream into memory, it negates the benefits of streams. It's intended for interoperability and convenience, not as the primary way to consume streams.
Parameters
| Parameter | Type |
|---|---|
options? | Pick<ArrayOptions, "signal"> |
Returns
Promise<any[]>
a promise containing an array with the contents of the stream.
Inherited from
Omit.toArray
Since
v17.5.0
unpipe()
unpipe(
destination?):this
The readable.unpipe() method detaches a Writable stream previously attached
using the pipe method.
If the destination is not specified, then all pipes are detached.
If the destination is specified, but no pipe is set up for it, then
the method does nothing.
const fs = require('node:fs');
const readable = getReadableStreamSomehow();
const writable = fs.createWriteStream('file.txt');
// All the data from readable goes into 'file.txt',
// but only for the first second.
readable.pipe(writable);
setTimeout(() => {
console.log('Stop writing to file.txt.');
readable.unpipe(writable);
console.log('Manually close the file stream.');
writable.end();
}, 1000);
Parameters
| Parameter | Type | Description |
|---|---|---|
destination? | WritableStream | Optional specific stream to unpipe |
Returns
this
Inherited from
Omit.unpipe
Since
v0.9.4
wrap()
wrap(
stream):this
Prior to Node.js 0.10, streams did not implement the entire node:stream module API as it is currently defined. (See Compatibility for more
information.)
When using an older Node.js library that emits 'data' events and has a pause method that is advisory only, the readable.wrap() method can be used to create a Readable
stream that uses
the old stream as its data source.
It will rarely be necessary to use readable.wrap() but the method has been
provided as a convenience for interacting with older Node.js applications and
libraries.
const { OldReader } = require('./old-api-module.js');
const { Readable } = require('node:stream');
const oreader = new OldReader();
const myReader = new Readable().wrap(oreader);
myReader.on('readable', () => {
myReader.read(); // etc.
});
Parameters
| Parameter | Type | Description |
|---|---|---|
stream | ReadableStream | An "old style" readable stream |
Returns
this
Inherited from
Omit.wrap
Since
v0.9.4