paldepind/flyd-takeuntil
Emit values from a stream until a second stream emits a value.
Functions for working with stream in objects.
This repository is cataloged as part of our automated global GitHub synchronization. Full telemetry, velocity snapshots, and code summaries are scheduled for continuous enrichment.
Emit values from a stream until a second stream emits a value.
Creates a stream with emits a list of all values from the source stream that where emitted in a specified duration.
Flyd module that buffers values from a stream and emits them after a specified duration of silience.
Flyd module for conveniently merging and reducing several streams into one.