Module: operators
Functions
consume
▸ consume<T>(rows): Promise<void>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
rows | AsyncIterable<T> |
Returns
Promise<void>
count
▸ count<T>(iterable): Promise<number>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
iterable | AsyncIterable<T> |
Returns
Promise<number>
first
▸ first<T>(iterable): Promise<T>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
iterable | AsyncIterable<T> |
Returns
Promise<T>
reduce
▸ reduce<T, TResult>(reducer, initialValue): (rows: AsyncIterable<T>) => Promise<TResult>
Type parameters
| Name |
|---|
T |
TResult |
Parameters
| Name | Type |
|---|---|
reducer | (acc: TResult, current: T) => TResult |
initialValue | TResult |
Returns
fn
▸ (rows): Promise<TResult>
Parameters
| Name | Type |
|---|---|
rows | AsyncIterable<T> |
Returns
Promise<TResult>
toArray
▸ toArray<T>(iterable): Promise<T[]>
Type parameters
| Name |
|---|
T |
Parameters
| Name | Type |
|---|---|
iterable | AsyncIterable<T> |
Returns
Promise<T[]>