A Stream of activated jobs of type. Repeatedly calls activateJobs (through the
/effect client Layer, i.e. the same backpressure-aware runtime the Promise worker
uses) and emits each activated job. The between-empty-polls delay and the optional
activation-retry Schedule both run on the Effect Clock, so TestClock.adjust
advances them deterministically in tests.
A
Streamof activated jobs oftype. Repeatedly callsactivateJobs(through the/effectclientLayer, i.e. the same backpressure-aware runtime the Promise worker uses) and emits each activated job. The between-empty-polls delay and the optional activation-retryScheduleboth run on the EffectClock, soTestClock.adjustadvances them deterministically in tests.