can we put this into AEUtils or so? maybe get sink out of the name, then it can be reused for querying stream delay.