ix
Options
All
  • Public
  • Public/Protected
  • All
Menu

Type parameters

  • TSource

Hierarchy

  • AsyncIterableX<TSource>
    • TapAsyncIterable

Implements

  • AsyncIterable<TSource>

Index

Modules

Constructors

Properties

Methods

Constructors

constructor

Properties

Private _observer

_observer: PartialAsyncObserver<TSource>

Private _source

_source: AsyncIterable<TSource>

Static average

average: averageProto

Static buffer

buffer: bufferProto

Static catch

catch: catchProto

Static catchWith

catchWith: catchWithProto

Static chain

chain: chainProto

Static combineLatest

combineLatest: combineLatestProto

Static concat

concat: concatProto

Static concatAll

concatAll: concatAllProto

Static count

count: countProto

Static debounce

debounce: debounceProto

Static defaultIfEmpty

defaultIfEmpty: defaultIfEmptyProto

Static distinct

distinct: distinctProto

Static distinctUntilChanged

distinctUntilChanged: distinctUntilChangedProto

Static doWhile

doWhile: doWhileProto

Static elementAt

elementAt: elementAtProto

Static endWith

endWith: endWithProto

Static every

every: everyProto

Static except

except: exceptProto

Static expand

expand: expandProto

Static filter

filter: filterProto

Static finally

finally: finallyProto

Static find

find: findProto

Static findIndex

findIndex: findIndexProto

Static first

first: firstProto

Static flatMap

flatMap: flatMapProto

Static flatten

flatten: flattenProto

Static forkJoin

forkJoin: forkJoinProto

Static groupBy

groupBy: groupByProto

Static groupJoin

groupJoin: groupJoinProto

Static ignoreElements

ignoreElements: ignoreElementsProto

Static includes

includes: includesProto

Static innerJoin

innerJoin: innerJoinProto

Static intersect

intersect: intersectProto

Static isEmpty

isEmpty: isEmptyProto

Static last

last: lastProto

Static map

map: mapProto

Static max

max: maxProto

Static maxBy

maxBy: maxByProto

Static memoize

memoize: memoizeProto

Static merge

merge: mergeProto

Static mergeAll

mergeAll: mergeAllProto

Static min

min: minProto

Static minBy

minBy: minByProto

Static onErrorResumeNext

onErrorResumeNext: onErrorResumeNextProto

Static orderBy

orderBy: orderByProto

Static orderByDescending

orderByDescending: orderByDescendingProto

Static pairwise

pairwise: pairwiseProto

Static partition

partition: partitionProto

Static pluck

pluck: pluckProto

Static publish

publish: publishProto

Static reduce

reduce: reduceProto

Static reduceRight

reduceRight: reduceRightProto

Static repeat

repeat: repeatProto

Static retry

retry: retryProto

Static reverse

reverse: reverseProto

Static scan

scan: scanProto

Static scanRight

scanRight: scanRightProto

Static sequenceEqual

sequenceEqual: sequenceEqualProto

Static share

share: shareProto

Static single

single: singleProto

Static skip

skip: skipProto

Static skipLast

skipLast: skipLastProto

Static skipUntil

skipUntil: skipUntilProto

Static skipWhile

skipWhile: skipWhileProto

Static slice

slice: sliceProto

Static some

some: someProto

Static startWith

startWith: startWithProto

Static sum

sum: sumProto

Static take

take: takeProto

Static takeLast

takeLast: takeLastProto

Static takeUntil

takeUntil: takeUntilProto

Static takeWhile

takeWhile: takeWhileProto

Static tap

tap: tapProto

Static throttle

throttle: throttleProto

Static toArray

toArray: toArrayProto

Static toMap

toMap: toMapProto

Static toObservable

toObservable: toObservableProto

Static toSet

toSet: toSetProto

Static union

union: unionProto

Static zip

zip: zipProto

Methods

__@asyncIterator

  • __@asyncIterator(): AsyncIterableIterator<TSource>

forEach

  • forEach(projection: function, thisArg?: any): Promise<void>

  • Parameters

    • projection: function
        • (value: TSource, index: number): void | Promise<void>

        • Parameters

          • value: TSource
          • index: number

          Returns void | Promise<void>

    • Optional thisArg: any

    Returns Promise<void>

pipe

Static as

  • as(source: string): AsyncIterableX<string>
  • as<T>(source: AsyncIterableInput<T>): AsyncIterableX<T>
  • as<T>(source: T): AsyncIterableX<T>

Static from

  • from<TSource, TResult>(source: AsyncIterableInput<TSource>, selector?: function, thisArg?: any): AsyncIterableX<TResult>

  • Type parameters

    • TSource

    • TResult

    Parameters

    • source: AsyncIterableInput<TSource>
    • Default value selector: function = identityAsync
        • (value: TSource, index: number): TResult | Promise<TResult>

        • Parameters

          • value: TSource
          • index: number

          Returns TResult | Promise<TResult>

    • Optional thisArg: any

    Returns AsyncIterableX<TResult>

Static of

  • of<TSource>(...args: TSource[]): AsyncIterableX<TSource>

Static pipe

  • pipe(): AsyncIterableX<TSource>

Legend

  • Module
  • Object literal
  • Variable
  • Function
  • Function with type parameter
  • Index signature
  • Type alias
  • Enumeration
  • Enumeration member
  • Property
  • Method
  • Interface
  • Interface with type parameter
  • Constructor
  • Property
  • Method
  • Index signature
  • Class
  • Class with type parameter
  • Constructor
  • Property
  • Method
  • Accessor
  • Index signature
  • Inherited constructor
  • Inherited property
  • Inherited method
  • Inherited accessor
  • Protected property
  • Protected method
  • Protected accessor
  • Private property
  • Private method
  • Private accessor
  • Static property
  • Static method

Generated using TypeDoc