@tsdrivers/mssql / PooledQueryStream
Class: PooledQueryStream<T>
Defined in: projects/ts-mssql/core/pool.ts:199
A QueryStream that holds a pooled connection and releases it when closed.
Type Parameters
T
T = Record<string, unknown>
Implements
AsyncIterable<T>DisposableAsyncDisposable
Methods
[asyncDispose]()
[asyncDispose]():
Promise<void>
Defined in: projects/ts-mssql/core/pool.ts:260
Returns
Promise<void>
Implementation of
AsyncDisposable.[asyncDispose]
[asyncIterator]()
[asyncIterator]():
AsyncIterableIterator<T>
Defined in: projects/ts-mssql/core/pool.ts:210
Returns
AsyncIterableIterator<T>
Implementation of
AsyncIterable.[asyncIterator]
[dispose]()
[dispose]():
void
Defined in: projects/ts-mssql/core/pool.ts:255
Returns
void
Implementation of
Disposable.[dispose]
close()
close():
Promise<void>
Defined in: projects/ts-mssql/core/pool.ts:250
Returns
Promise<void>
filter()
filter(
fn):Promise<T[]>
Defined in: projects/ts-mssql/core/pool.ts:232
Parameters
fn
(row) => boolean
Returns
Promise<T[]>
map()
map<
U>(fn):Promise<U[]>
Defined in: projects/ts-mssql/core/pool.ts:226
Type Parameters
U
U
Parameters
fn
(row) => U
Returns
Promise<U[]>
reduce()
reduce<
U>(fn,initial):Promise<U>
Defined in: projects/ts-mssql/core/pool.ts:240
Type Parameters
U
U
Parameters
fn
(acc, row) => U
initial
U
Returns
Promise<U>
toArray()
toArray():
Promise<T[]>
Defined in: projects/ts-mssql/core/pool.ts:220
Returns
Promise<T[]>
toReadableStream()
toReadableStream():
ReadableStream<T>
Defined in: projects/ts-mssql/core/pool.ts:246
Returns
ReadableStream<T>