merge | /mod.ts | rxjs@v1.0.2

Module

x/rxjs/mod.ts>merge

Deno port of RXJS

ziv/deno-rxjs

Latest

ajax fetch internal operators testing webSocket

mod.ts (default module)

AsyncSubject

BehaviorSubject

ConnectableObservable

ArgumentOutOfRangeError

GroupByOptionsWithElement

GroupedObservable

InteropObservable

MonoTypeOperatorFunction

NextNotification

NextObserver

NotFoundError

ObjectUnsubscribedError

ObservableNotification

ObservedValueOf

ObservedValuesFromArray

ObservedValueTupleFromArray

ObservedValueUnionFromArray

PartialObserver

SubscribableOrPromise

ValueFromNotification

animationFrame

animationFrameScheduler

distinctUntilKeyChanged

iif

map

max

min

tap

zip

function merge

import { merge } from "https://deno.land/x/rxjs@v1.0.2/mod.ts";

merge<A extends readonly unknown[]>(...sources: [...ObservableInputTuple<A>]): Observable<A[number]>

merge<A extends readonly unknown[]>(...sourcesAndConcurrency: [...ObservableInputTuple<A>, number]): Observable<A[number]>

Deprecated

The scheduler parameter will be removed in v8. Use scheduled and mergeAll. Details: https://rxjs.dev/deprecations/scheduler-argument

merge<A extends readonly unknown[]>(...sourcesAndScheduler: [...ObservableInputTuple<A>, SchedulerLike]): Observable<A[number]>

Deprecated

The scheduler parameter will be removed in v8. Use scheduled and mergeAll. Details: https://rxjs.dev/deprecations/scheduler-argument

merge<A extends readonly unknown[]>(...sourcesAndConcurrencyAndScheduler: [...ObservableInputTuple<A>, number, SchedulerLike]): Observable<A[number]>

Type Parameters

A extends readonly unknown[]

Parameters

...sources: [...ObservableInputTuple<A>]

Returns

Observable<A[number]>

Type Parameters

A extends readonly unknown[]

Parameters

...sourcesAndConcurrency: [...ObservableInputTuple<A>, number]

Returns

Observable<A[number]>

Type Parameters

A extends readonly unknown[]

Parameters

...sourcesAndScheduler: [...ObservableInputTuple<A>, SchedulerLike]

Returns

Observable<A[number]>

Type Parameters

A extends readonly unknown[]

Parameters

...sourcesAndConcurrencyAndScheduler: [...ObservableInputTuple<A>, number, SchedulerLike]

Returns

Observable<A[number]>