libtcspc.RecoverOrder¶

final class libtcspc.RecoverOrder(time_window, numeric_traits=None)[source]¶

Bases: Node

Pass-through processor that sorts events by abstime within a time window.

Buffers events and emits them in non-decreasing abstime order once each is at least time_window behind the latest received event. If an event arrives that is older than the latest by more than time_window, an error is raised.

Parameters:

time_window (int or Param[int]) – Maximum abstime range over which events may be out of order. Must be non-negative.
numeric_traits (NumericTraits or None) – Numeric traits specifying abstime_type. Defaults to NumericTraits().

Notes

Events handled:

All event types with an abstime field: buffered and forwarded in abstime order once time_window has elapsed.
End of input: emit any buffered events in abstime order; pass through.