servicex.utils.stream_unique_updates_only#

async servicex.utils.stream_unique_updates_only(stream: AsyncIterator[Tuple[Optional[int], int, Optional[int]]])[source]#

As status goes by, only let through changes