Skip to content

@jtopo/core / Observable

Class: Observable

Table of contents

Constructors

Methods

Constructors

constructor

new Observable()

Methods

bufferCount

bufferCount(n, m?): Observable

Parameters

NameTypeDefault value
nnumberundefined
mnumber1

Returns

Observable


debounceTime

debounceTime(time): Observable

Parameters

NameType
timenumber

Returns

Observable


delay

delay(time): Observable

Parameters

NameType
timenumber

Returns

Observable


distinct

distinct(): Observable

Returns

Observable


filter

filter(predicate): Observable

Parameters

NameType
predicate(value: any) => boolean

Returns

Observable


map

map(mapFn): Observable

Parameters

NameType
mapFn(value: any) => any

Returns

Observable


pairwise

pairwise(n?): Observable

Parameters

NameTypeDefault value
nnumber2

Returns

Observable


publish

publish(value): Observable

Parameters

NameType
valueany

Returns

Observable


reduce

reduce(reduceFn, initValue?): Observable

Parameters

NameType
reduceFnFunction
initValue?any

Returns

Observable


subscribe

subscribe(observer): Observable

Parameters

NameType
observerFunction

Returns

Observable


throttleTime

throttleTime(time): Observable

Parameters

NameType
timenumber

Returns

Observable


unsubscribe

unsubscribe(): void

Returns

void


fromEvent

Static fromEvent(target, eventType): Observable

Parameters

NameType
targetany
eventTypestring

Returns

Observable


of

Static of(...values): Observable

Parameters

NameType
...valuesany[]

Returns

Observable