Rewrite stream sources