Table of Contents

ajax
fetch
- fromFetch()
Guide
index
operators
- audit()
- auditTime()
- buffer()
- bufferCount()
- bufferTime()
- bufferToggle()
- bufferWhen()
- catchError()
- combineAll
- combineLatest()
- combineLatestAll()
- combineLatestWith()
- concat()
- concatAll()
- concatMap()
- concatMapTo()
- concatWith()
- connect()
- count()
- debounce()
- debounceTime()
- defaultIfEmpty()
- delay()
- delayWhen()
- dematerialize()
- distinct()
- distinctUntilChanged()
- distinctUntilKeyChanged()
- elementAt()
- endWith()
- every()
- exhaust
- exhaustAll()
- exhaustMap()
- expand()
- filter()
- finalize()
- find()
- findIndex()
- first()
- flatMap
- groupBy()
- ignoreElements()
- isEmpty()
- last()
- map()
- mapTo()
- materialize()
- max()
- merge()
- mergeAll()
- mergeMap()
- mergeMapTo()
- mergeScan()
- mergeWith()
- min()
- multicast()
- observeOn()
- onErrorResumeNext()
- pairwise()
- partition()
- pluck()
- publish()
- publishBehavior()
- publishLast()
- publishReplay()
- race()
- raceWith()
- reduce()
- refCount()
- repeat()
- repeatWhen()
- retry()
- retryWhen()
- sample()
- sampleTime()
- scan()
- sequenceEqual()
- share()
- shareReplay()
- single()
- skip()
- skipLast()
- skipUntil()
- skipWhile()
- startWith()
- subscribeOn()
- switchAll()
- switchMap()
- switchMapTo()
- switchScan()
- take()
- takeLast()
- takeUntil()
- takeWhile()
- tap()
- throttle()
- throttleTime()
- throwIfEmpty()
- timeInterval()
- timeout()
- timeoutWith()
- timestamp()
- toArray()
- window()
- windowCount()
- windowTime()
- windowToggle()
- windowWhen()
- withLatestFrom()
- zip()
- zipAll()
- zipWith()
testing
webSocket

connectable

function stable

Creates an observable that multicasts once connect() is called on it.

`connectable<T>(source: ObservableInput<T>, config: ConnectableConfig<T> = DEFAULT_CONFIG): Connectable<T>`

Parameters

source

ObservableInput<T>

The observable source to make connectable.

config

ConnectableConfig<T>

Optional. Default is DEFAULT_CONFIG.

The configuration object for connectable.

Returns

Connectable<T>: A "connectable" observable, that has a connect() method, that you must call to connect the source to all consumers through the subject provided as the connector.

© 2015–2022 Google, Inc., Netflix, Inc., Microsoft Corp. and contributors.
Code licensed under an Apache-2.0 License. Documentation licensed under CC BY 4.0.
https://rxjs.dev/api/index/function/connectable