Support concat of an already-flowing stream