OptionalbaseBase backoff delay in milliseconds.
OptionallogDiagnostic log callback.
OptionalmaxBackoff delay cap in milliseconds.
OptionalsignalAbort signal that cancels an in-progress backoff sleep.
OptionalsuccessMinimum attempt duration that counts as a successful read even with zero events.
OptionalisClassifies an error as unretryable. Defaults to isTerminalSubscribeError.
OptionalonCalled before every backoff-and-resubscribe transition.
OptionalrandomUniform [0, 1) random source used for jitter.
Performs one subscribe-and-consume cycle. Call reportActivity() for
every event received so the engine can reset its failure counter.
Return "ended" on a clean stream end, "stop" when the attempt
already finalized the connection, or throw on error.
Checked between attempts; true stops the loop with "stopped".
OptionalsleepSleep implementation; must resolve early when signal aborts.
Optionalsignal: AbortSignal
Options for runStreamResubscribeLoop.