clerx

clerx 💁

A Timely Suite of RxJS Operators and Observables

Install

npm install clerx

Try out the example

Operators

rateLimiter(count, slidingWindowTime)

Defer sending events if count events occur within slidingWindowTime. Optionally, stop deferring if the wait time goes past timeoutDue.

Examples

Only two events within three seconds

abcdef--g---

> rateLimiter(2, 3000)

ab-cd-ef-g--

Only one event within five seconds

-(abc)def

> rateLimiter(1, 5000)

-a----b----c----d----e----f----

Observables

postDelay(event: T, dueTime): Observable<T>

Creates an observable that emits the event then waits dueTime before closing the observable, like so:

event--{ dueTime }--|

Delay 5 seconds after emitting an event

> postDelay("a", 5000)

a----|

intervalBackoff(backoff: number): Observable<number>

Creates an Observable that emits sequential numbers in an exponentially increasing interval of time.

exponentially increasing delay starting at a one second interval