servicex.utils.stream_status_updates# async servicex.utils.stream_status_updates(stream: AsyncIterator[Tuple[Optional[int], int, Optional[int]]], notifier: _status_update_wrapper)[source]# As the transformed status goes by, update the notifier with the new values.