iya-sts
    Preparing search index...

    Variable notePushFailure

    notePushFailure: (
        record?: any,
        why?: any,
        nowMs?: any,
    ) => { declaredDead: boolean; moved: number } = ...

    Type Declaration

      • (record?: any, why?: any, nowMs?: any): { declaredDead: boolean; moved: number }
      • Records a failed push, declaring the stream dead (and moving its queue to the dead letters) when nothing has been delivered for the timeout.

        Parameters

        • Optionalrecord: any

          the stream

        • Optionalwhy: any

          the failure

        • OptionalnowMs: any

          the current time, for tests

        Returns { declaredDead: boolean; moved: number }

        { declaredDead, moved }