pub fn reenqueue_orphaned_stream( pool: PgPool, config: Config, interval: Duration, ) -> impl Stream<Item = Result<u64, Error>> + Send