HitMerger

class waveline.utils.HitMerger(max_queue_size=None)

Merge AE and TR records into HitRecords based on the transient recorder index (trai).

Since AE and TR records arrive in order for each channel, AE records are stored in channel-specific queues and merged with corresponding TR records as they become available.

__init__(max_queue_size=None)

Initialize the HitMerger with an optional maximum queue size.

Parameters:

max_queue_size (int | None) – Maximum queue size for each channel. If None, queues are unbounded.

Methods

__init__([max_queue_size])	Initialize the HitMerger with an optional maximum queue size.
clear()	Clear all buffered AE records.
process(record)	Process a single AE or TR record.

class ChannelState(queue, last_trai=0)

clear()

Clear all buffered AE records.

process(record)

Process a single AE or TR record.

Return type:

HitRecord | None

Returns:

HitRecord if a merge occurred, otherwise None.

Raises:

QueueFullError – If the queue for a channel is full when processing an AERecord.