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>