ahmido
1fec9c6f9d
Some checks failed
Main Confidence / confidence (push) Failing after 45s
## Summary - introduce surface-aware compressed governance outcomes and reuse the shared truth/explanation seams for operator-first summaries - apply the compressed outcome hierarchy across baseline, evidence, review, review-pack, canonical review/evidence, and artifact-oriented operation-run surfaces - expand spec 214 fixtures and Pest coverage, and fix tenant-panel route assertions by generating explicit tenant-panel URLs in the affected Filament tests ## Validation - `cd apps/platform && ./vendor/bin/sail bin pint --dirty --format agent` - focused governance compression suite from `specs/214-governance-outcome-compression/quickstart.md` passed (`68` tests, `445` assertions) - `cd apps/platform && ./vendor/bin/sail artisan test --compact tests/Feature/Filament/InventoryItemResourceTest.php tests/Feature/Filament/BackupSetUiEnforcementTest.php tests/Feature/Filament/RestoreRunUiEnforcementTest.php` passed (`18` tests, `81` assertions) Co-authored-by: Ahmed Darrazi <ahmed.darrazi@live.de> Reviewed-on: #253
61 lines
2.6 KiB
Plaintext
61 lines
2.6 KiB
Plaintext
import { Subscription } from '../Subscription';
|
|
import { operate } from '../util/lift';
|
|
import { createOperatorSubscriber } from './OperatorSubscriber';
|
|
import { arrRemove } from '../util/arrRemove';
|
|
import { asyncScheduler } from '../scheduler/async';
|
|
import { popScheduler } from '../util/args';
|
|
import { executeSchedule } from '../util/executeSchedule';
|
|
export function bufferTime(bufferTimeSpan, ...otherArgs) {
|
|
var _a, _b;
|
|
const scheduler = (_a = popScheduler(otherArgs)) !== null && _a !== void 0 ? _a : asyncScheduler;
|
|
const bufferCreationInterval = (_b = otherArgs[0]) !== null && _b !== void 0 ? _b : null;
|
|
const maxBufferSize = otherArgs[1] || Infinity;
|
|
return operate((source, subscriber) => {
|
|
let bufferRecords = [];
|
|
let restartOnEmit = false;
|
|
const emit = (record) => {
|
|
const { buffer, subs } = record;
|
|
subs.unsubscribe();
|
|
arrRemove(bufferRecords, record);
|
|
subscriber.next(buffer);
|
|
restartOnEmit && startBuffer();
|
|
};
|
|
const startBuffer = () => {
|
|
if (bufferRecords) {
|
|
const subs = new Subscription();
|
|
subscriber.add(subs);
|
|
const buffer = [];
|
|
const record = {
|
|
buffer,
|
|
subs,
|
|
};
|
|
bufferRecords.push(record);
|
|
executeSchedule(subs, scheduler, () => emit(record), bufferTimeSpan);
|
|
}
|
|
};
|
|
if (bufferCreationInterval !== null && bufferCreationInterval >= 0) {
|
|
executeSchedule(subscriber, scheduler, startBuffer, bufferCreationInterval, true);
|
|
}
|
|
else {
|
|
restartOnEmit = true;
|
|
}
|
|
startBuffer();
|
|
const bufferTimeSubscriber = createOperatorSubscriber(subscriber, (value) => {
|
|
const recordsCopy = bufferRecords.slice();
|
|
for (const record of recordsCopy) {
|
|
const { buffer } = record;
|
|
buffer.push(value);
|
|
maxBufferSize <= buffer.length && emit(record);
|
|
}
|
|
}, () => {
|
|
while (bufferRecords === null || bufferRecords === void 0 ? void 0 : bufferRecords.length) {
|
|
subscriber.next(bufferRecords.shift().buffer);
|
|
}
|
|
bufferTimeSubscriber === null || bufferTimeSubscriber === void 0 ? void 0 : bufferTimeSubscriber.unsubscribe();
|
|
subscriber.complete();
|
|
subscriber.unsubscribe();
|
|
}, undefined, () => (bufferRecords = null));
|
|
source.subscribe(bufferTimeSubscriber);
|
|
});
|
|
}
|
|
//# sourceMappingURL=bufferTime.js.map |