Skip to content

@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>
  • Disposable
  • AsyncDisposable

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>