nanover.trajectory.frame_queue module

class nanover.trajectory.frame_queue.FrameMergingQueue

Bases: LastItemQueue[FrameData]

SingleItemQueue specifically for FrameData items. Put frames will be aggregated with any existing frame so that there is at most one frame in the queue at any time.

close()

put(item: FrameData | None, **kwargs)

Store a value, replace the previous one if any.

This method is thread-safe and is meant to be a drop in replacement to Queue.put().

Parameters:

• item – The value to store.

• kwargs – Unused arguments for compatibility with Queue.put().