Einar Norðfjörð
Einar Norðfjörð
The issue came about because the test is asynchronous but wasn't supplied a done callback. This lead to a swallowed error. This commit fixes the test such that it gives...
This issue was caused by #180 which made sure that nested streams were updated properly. Updating them properly caused nested takeUntil'd streams to end too soon. This closes #188
The takeUntil module violates one of the first principles of functional programming. Its argument order was (src, end) which is a data first argument order. This PR flips the argument...
Steps to reproduce Open this fiddle on chrome on a mac http://jsfiddle.net/3rtfqpm6/ click the result tab and press `ctrl+left` Expected result: Alert box with 'Hi' Actual result: Nothing happens
This would be useful in cases where you're doing batch processing. ```ts const start = process.hrtime.bigint(); await doBatchProcessing(batch) const duration = Number(process.hrtime.bigint() - start) / 1e9 // record the histogram...
Currently the cache instance creates an interval under the hood and there's no way to clear this interval. This effectively results in memory leaks when e.g. running a jest test...
Some entities have events that could be considered reset events. That is, after these events are appended the prior history ceases to matter in regards to the current state of...
Tested against DynamoStore
Adds some basic telemetry to the ingestion pipeline. All attributes are prefixed with `propulsion.` | Attribute | Description | |----------|------------| | `category` | The category being processed | | `stream_name`...