Skip to content

mssql-ts-ffi / PooledQueryStream

Class: PooledQueryStream<T> ​

Defined in: pool.ts:169

A QueryStream that holds a pooled connection and releases it when closed.

Type Parameters ​

T ​

T = Record<string, unknown>

Implements ​

  • AsyncIterable<T>
  • AsyncDisposable

Methods ​

[asyncDispose]() ​

[asyncDispose](): Promise<void>

Defined in: pool.ts:225

Returns ​

Promise<void>

Implementation of ​

AsyncDisposable.[asyncDispose]


[asyncIterator]() ​

[asyncIterator](): AsyncIterableIterator<T>

Defined in: pool.ts:180

Returns ​

AsyncIterableIterator<T>

Implementation of ​

AsyncIterable.[asyncIterator]


close() ​

close(): Promise<void>

Defined in: pool.ts:220

Returns ​

Promise<void>


filter() ​

filter(fn): Promise<T[]>

Defined in: pool.ts:202

Parameters ​

fn ​

(row) => boolean

Returns ​

Promise<T[]>


map() ​

map<U>(fn): Promise<U[]>

Defined in: pool.ts:196

Type Parameters ​

U ​

U

Parameters ​

fn ​

(row) => U

Returns ​

Promise<U[]>


reduce() ​

reduce<U>(fn, initial): Promise<U>

Defined in: pool.ts:210

Type Parameters ​

U ​

U

Parameters ​

fn ​

(acc, row) => U

initial ​

U

Returns ​

Promise<U>


toArray() ​

toArray(): Promise<T[]>

Defined in: pool.ts:190

Returns ​

Promise<T[]>


toReadableStream() ​

toReadableStream(): ReadableStream<T>

Defined in: pool.ts:216

Returns ​

ReadableStream<T>