subscriber is now a stream