added partial support for stream subscription, example update