RxJS buffer function calls

100%

RxJS buffer function calls

✓ Published0🌍 Public

Last edited Feb 6, 2018

Created on Feb 6, 2018

This example demonstrates how RxJS can batch function calls into buffered groups using the `Subject` API. The code creates a `bufferTime` operator that collects invocations over 500 milliseconds, up to a maximum of three items, before emitting them as an array. A custom `batchify` helper subscribes to the buffered observable and logs each batch of arguments before passing them to the target function. The main loop asynchronously invokes the batched function with increasing numbers, then quickly fires three more calls to trigger a final buffered output.

AI-generated description

Similar vizzes

Loading thumbnail…

run promises sequentially or not using observables

This example demonstrates how to execute arrays of promises sequentially or in controlled batches using RxJS observables. It shows a stream of numeric values piped through operators like `map`, `defer`, and `mergeAll` with a concurrency limit of 1, ensuring each promise resolves before the next starts. A second variant uses `bufferCount(3)` to group the input into batches of three, still processing them one batch at a time. The `delay` helper creates promises that log their resolved values to the console, with a final `console.log('done')` indicating stream completion.

RRestuta

65% match

Loading thumbnail…

RxJS Switch Map

This example demonstrates the behavior of RxJS’s `switchMap` operator when combined with a custom sorter function that merges values from two observable streams. The code creates two observables emitting numbers (1,2,3 and 40,50,60) and passes them through `switchMap` with a `createSorter` callback that accumulates, sorts, and pops values from an internal list. Each emitted value is logged to the console, showing how `switchMap` switches between the source observables while the sorter maintains state across emissions. The gist uses RxJS’s `Observable.of` and `subscribe` methods.

RRestuta

56% match

Loading thumbnail…

JS Bin

This example demonstrates a live counter that updates every second, displaying the number of elapsed seconds in the browser and the console. It uses RxJS’s `Observable.timer` to emit sequential integers, which are mapped to formatted strings. The resulting data stream is subscribed to by two effects: a DOM effect that writes the text into a `#app` container, and a console effect that logs each message. The code separates the main data stream from its side effects, following a simple functional reactive programming pattern.

JJaxonDvl

54% match

Loading thumbnail…

Hello Reactor

This example demonstrates a minimal event-driven communication system built with JavaScript. It shows how two listeners attached to the same `'big bang'` event respond to a dispatched payload, with one listener logging a fixed message and the other printing the passed arguments. The code defines a custom `Reactor` class and an `Event` class, showcasing manual event registration, callback storage, and dispatch logic. The implementation relies on JavaScript's array `forEach` method to invoke all registered callbacks with the spread `...eventArgs` syntax. The data originates from a hardcoded dispatch call passing the values `135`, `'test'`, and `[1, 2, 3]`.

MMAKIO135

51% match

Loading thumbnail…

async-for-each

This example demonstrates a sequential asynchronous loop over an array, where each item is processed only after the previous callback completes. It shows how `asyncForEach` awaits a user-provided callback that delays execution using a custom `waitFor` promise wrapper around `setTimeout`. The code uses the native `async`/`await` syntax and a `for` loop to ensure the array `[1, 2, 3]` is logged in order, with a one-second pause between each item. The visible data source is a hardcoded array in the `start` function, and the rendering approach is console output.

AA6Brgeuka

50% match

Loading thumbnail…

Observable JS Demo

This demo shows the Observable JS runtime running inside a plain HTML page using the `@hpcc-js/observable-md` library. It loads a `.ojs` file containing markdown, a generator that emits a ticking counter at 1-second intervals, and an imported brushable scatterplot from `@d3/brushable-scatterplot`. The user’s selection on that plot is displayed as a live JSON preview. The page resizes dynamically via the `Observable` API’s `resize()` and `lazyRender()` methods.

GGordonSmith

49% match

Loading thumbnail…

Effect Functor / Reader Monad

This example demonstrates functional programming patterns—an Effect functor and Reader monad—as JavaScript objects with methods like `map`, `chain`, `join`, and `ap`. The Effect wraps an impure function like `fZero`, while `Effect.of` creates a pure initial value. The Reader monad, using `Reader.ask`, threads a shared environment (a database and logger) through a composed `updateTask` pipeline. The code simulates a database update and logging by explicitly invoking `run` with those dependencies, showing how side effects are deferred and composed without direct state mutation.

RRestuta

48% match

Loading thumbnail…

Gist d51a566a307b428d98eaf3aa8d2a59a3

This example benchmarks JavaScript event emitter libraries across multiple test scenarios, including initialization, emitting with context, and emitting single or multiple values to one or more listeners. The code runs benchmark suites using `benchmark.js`, comparing libraries such as `EventEmitter3`, `MiniSignals`, `push-stream`, and `signal-lite`, and reports throughput in operations per second. It highlights the fastest performers per scenario, such as `push-stream` leading in the "emit with context" test. The visualization shows raw performance data from Node.js 6.2.1, rendered as plain-text tables with pass/fail assertions and timing summaries.

HHypercubed

48% match