FlatMapIterator | plannerjs

This AsyncIterator maps every item of a query AsyncIterator to a result AsyncIterator by passing it through a run function. All result AsyncIterator get concatenated to form the FlatMapIterator

                 +-----+                     +-----+
  queryIterator  |0 & 9| +---+             + |1 & 8| +---+             + ...
                 +-----+     |               +-----+     |
                             v                           v
                 +-----------------------+   +-----------------------+
resultIterators  |01|02|04|05|06|07|08|09| + |11|12|13|14|15|16|17|18| + ...
                 +-----------------------+   +-----------------------+

                 +-----------------------------------------------+
FlatMapIterator  |01|02|04|05|06|07|08|09|11|12|13|14|15|16|17|18| ...
                 +-----------------------------------------------+

Type parameters

Hierarchy

AsyncIterator<R>
- FlatMapIterator

Index

Constructors

constructor

Properties

Constructors

constructor

new FlatMapIterator(queryIterator: AsyncIterator<Q>, run: function): FlatMapIterator

Overrides AsyncIterator.constructor
- Defined in src/util/iterators/FlatMapIterator.ts:26
Parameters
- queryIterator: AsyncIterator<Q>
- run: function
  - - (query: Q): AsyncIterator<R>
    - Parameters
      - query: Q
      Returns AsyncIterator<R>
Returns FlatMapIterator

Properties

Optional _destination

_destination: AsyncIterator<any>

_readable

_readable: boolean

_state

_state: number

closed

closed: boolean

ended

ended: boolean

readable

readable: boolean

Static CLOSED

CLOSED: 3

Static CLOSING

CLOSING: 2

Static ENDED

ENDED: 4

Static INIT

INIT: 0

Static OPEN

OPEN: 1

Static STATES

STATES: ["INIT", "OPEN", "CLOSING", "CLOSED", "ENDED"]

Static defaultMaxListeners

defaultMaxListeners: number

Methods

_changeState

_changeState(newState: number, eventAsync?: boolean): void

Inherited from AsyncIterator._changeState
- Defined in src/asynciterator.d.ts:33
Parameters
- newState: number
- Optional eventAsync: boolean
Returns void

_end

_end(): void

Inherited from AsyncIterator._end
- Defined in src/asynciterator.d.ts:40
Returns void

_toStringDetails

_toStringDetails(): string

Inherited from AsyncIterator._toStringDetails
- Defined in src/asynciterator.d.ts:54
Returns string

addListener

addListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.addListener

Overrides EventEmitter.addListener
- Defined in node_modules/@types/node/events.d.ts:32
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

append

append<T>(items: T[] | AsyncIterator<T>): SimpleTransformIterator<T, T>

Inherited from AsyncIterator.append
- Defined in src/asynciterator.d.ts:64
Type parameters
- T
Parameters
- items: T[] | AsyncIterator<T>
Returns SimpleTransformIterator<T, T>

clone

clone(): ClonedIterator<R>

Inherited from AsyncIterator.clone
- Defined in src/asynciterator.d.ts:74
Returns ClonedIterator<R>

close

close(): void

Inherited from AsyncIterator.close
- Defined in src/asynciterator.d.ts:31
Returns void

copyProperties

copyProperties(source: AsyncIterator<any>, propertyNames: string[]): void

Inherited from AsyncIterator.copyProperties
- Defined in src/asynciterator.d.ts:50
Parameters
- source: AsyncIterator<any>
- propertyNames: string[]
Returns void

each

each(callback: function, self?: any): void

Inherited from AsyncIterator.each
- Defined in src/asynciterator.d.ts:29
Parameters
- callback: function
  - - (data: R): void
    - Parameters
      - data: R
      Returns void
- Optional self: any
Returns void

emit

emit(event: string | symbol, ...args: any[]): boolean

Inherited from EventEmitter.emit

Overrides EventEmitter.emit
- Defined in node_modules/@types/node/events.d.ts:44
Parameters
- event: string | symbol
- Rest ...args: any[]
Returns boolean

eventNames

eventNames(): Array<string | symbol>

Inherited from EventEmitter.eventNames

Overrides EventEmitter.eventNames
- Defined in node_modules/@types/node/events.d.ts:45
Returns Array<string | symbol>

filter

filter(filter: function, self?: object): SimpleTransformIterator<R, R>

Inherited from AsyncIterator.filter
- Defined in src/asynciterator.d.ts:60
Parameters
- filter: function
  - - (item: R): boolean
    - Parameters
      - item: R
      Returns boolean
- Optional self: object
Returns SimpleTransformIterator<R, R>

getMaxListeners

getMaxListeners(): number

Inherited from EventEmitter.getMaxListeners

Overrides EventEmitter.getMaxListeners
- Defined in node_modules/@types/node/events.d.ts:41
Returns number

getProperties

getProperties(): object

Inherited from AsyncIterator.getProperties
- Defined in src/asynciterator.d.ts:46
Returns object
- [id: string]: any

getProperty

getProperty(propertyName: string, callback?: function): any

Inherited from AsyncIterator.getProperty
- Defined in src/asynciterator.d.ts:42
Parameters
- propertyName: string
- Optional callback: function
  - - (value: any): void
    - Parameters
      - value: any
      Returns void
Returns any

listenerCount

listenerCount(type: string | symbol): number

Inherited from EventEmitter.listenerCount

Overrides EventEmitter.listenerCount
- Defined in node_modules/@types/node/events.d.ts:46
Parameters
- type: string | symbol
Returns number

listeners

listeners(event: string | symbol): Function[]

Inherited from EventEmitter.listeners

Overrides EventEmitter.listeners
- Defined in node_modules/@types/node/events.d.ts:42
Parameters
- event: string | symbol
Returns Function[]

map

map<T2>(mapper: function, self?: object): SimpleTransformIterator<R, T2>

Inherited from AsyncIterator.map
- Defined in src/asynciterator.d.ts:58
Type parameters
- T2
Parameters
- mapper: function
  - - (item: R): T2
    - Parameters
      - item: R
      Returns T2
- Optional self: object
Returns SimpleTransformIterator<R, T2>

off

off(event: string | symbol, listener: function): this

Inherited from EventEmitter.off

Overrides EventEmitter.off
- Defined in node_modules/@types/node/events.d.ts:38
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

on

on(event: string | symbol, listener: function): this

Inherited from EventEmitter.on

Overrides EventEmitter.on
- Defined in node_modules/@types/node/events.d.ts:33
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

once

once(event: string | symbol, listener: function): this

Inherited from EventEmitter.once

Overrides EventEmitter.once
- Defined in node_modules/@types/node/events.d.ts:34
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

prepend

prepend(items: R[] | AsyncIterator<R>): SimpleTransformIterator<R, R>

Inherited from AsyncIterator.prepend
- Defined in src/asynciterator.d.ts:62
Parameters
- items: R[] | AsyncIterator<R>
Returns SimpleTransformIterator<R, R>

prependListener

prependListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.prependListener

Overrides EventEmitter.prependListener
- Defined in node_modules/@types/node/events.d.ts:35
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

prependOnceListener

prependOnceListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.prependOnceListener

Overrides EventEmitter.prependOnceListener
- Defined in node_modules/@types/node/events.d.ts:36
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

range

range<T>(start: number, end: number): SimpleTransformIterator<T, T>

Inherited from AsyncIterator.range
- Defined in src/asynciterator.d.ts:72
Type parameters
- T
Parameters
- start: number
- end: number
Returns SimpleTransformIterator<T, T>

rawListeners

rawListeners(event: string | symbol): Function[]

Inherited from EventEmitter.rawListeners

Overrides EventEmitter.rawListeners
- Defined in node_modules/@types/node/events.d.ts:43
Parameters
- event: string | symbol
Returns Function[]

read

read(): R

Overrides AsyncIterator.read
- Defined in src/util/iterators/FlatMapIterator.ts:41
Returns R

removeAllListeners

removeAllListeners(event?: string | symbol): this

Inherited from EventEmitter.removeAllListeners

Overrides EventEmitter.removeAllListeners
- Defined in node_modules/@types/node/events.d.ts:39
Parameters
- Optional event: string | symbol
Returns this

removeListener

removeListener(event: string | symbol, listener: function): this

Inherited from EventEmitter.removeListener

Overrides EventEmitter.removeListener
- Defined in node_modules/@types/node/events.d.ts:37
Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns this

setMaxListeners

setMaxListeners(n: number): this

Inherited from EventEmitter.setMaxListeners

Overrides EventEmitter.setMaxListeners
- Defined in node_modules/@types/node/events.d.ts:40
Parameters
- n: number
Returns this

setProperties

setProperties(properties: object): void

Inherited from AsyncIterator.setProperties
- Defined in src/asynciterator.d.ts:48
Parameters
- properties: object
  - [id: string]: any
Returns void

setProperty

setProperty(propertyName: string, value: any): void

Inherited from AsyncIterator.setProperty
- Defined in src/asynciterator.d.ts:44
Parameters
- propertyName: string
- value: any
Returns void

skip

skip<T>(offset: number): SimpleTransformIterator<T, T>

Inherited from AsyncIterator.skip
- Defined in src/asynciterator.d.ts:68
Type parameters
- T
Parameters
- offset: number
Returns SimpleTransformIterator<T, T>

surround

surround<T>(prepend: T[] | AsyncIterator<T>, append: T[] | AsyncIterator<T>): SimpleTransformIterator<T, T>

Inherited from AsyncIterator.surround
- Defined in src/asynciterator.d.ts:66
Type parameters
- T
Parameters
- prepend: T[] | AsyncIterator<T>
- append: T[] | AsyncIterator<T>
Returns SimpleTransformIterator<T, T>

take

take<T>(limit: number): SimpleTransformIterator<T, T>

Inherited from AsyncIterator.take
- Defined in src/asynciterator.d.ts:70
Type parameters
- T
Parameters
- limit: number
Returns SimpleTransformIterator<T, T>

toString

toString(): string

Inherited from AsyncIterator.toString
- Defined in src/asynciterator.d.ts:52
Returns string

transform

transform<T2>(options?: SimpleTransformIteratorOptions<R, T2>): SimpleTransformIterator<R, T2>

Inherited from AsyncIterator.transform
- Defined in src/asynciterator.d.ts:56
Type parameters
- T2
Parameters
- Optional options: SimpleTransformIteratorOptions<R, T2>
Returns SimpleTransformIterator<R, T2>

Static listenerCount

listenerCount(emitter: EventEmitter, event: string | symbol): number

Inherited from EventEmitter.listenerCount
- Defined in node_modules/@types/node/events.d.ts:29
deprecated

since v4.0.0

Parameters
- emitter: EventEmitter
- event: string | symbol
Returns number

Static range

range(start?: number, end?: number, step?: number): IntegerIterator

Inherited from AsyncIterator.range
- Defined in src/asynciterator.d.ts:76
Parameters
- Optional start: number
- Optional end: number
- Optional step: number
Returns IntegerIterator

Generated using TypeDoc

Type parameters

Q

R

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

queryIterator: AsyncIterator<Q>

run: function

Parameters

query: Q

Returns AsyncIterator<R>

Returns FlatMapIterator

Properties

Optional _destination

_readable

_state

closed

ended

readable

Static CLOSED

Static CLOSING

Static ENDED

Static INIT

Static OPEN

Static STATES

Static defaultMaxListeners

Methods

_changeState

Parameters

newState: number

Optional eventAsync: boolean

Returns void

_end

Returns void

_toStringDetails

Returns string

addListener

Parameters

event: string | symbol

listener: function

Parameters

Rest ...args: any[]

Returns void

Returns this

append

Type parameters

T

Parameters

items: T[] | AsyncIterator<T>

Returns SimpleTransformIterator<T, T>

clone

Returns ClonedIterator<R>

close

Returns void

copyProperties

Parameters

source: AsyncIterator<any>

propertyNames: string[]

Returns void

each

Parameters

callback: function

Parameters

data: R

Returns void

Optional self: any

Returns void

emit

Parameters

event: string | symbol

Rest ...args: any[]

Returns boolean

eventNames

Returns Array<string | symbol>

filter