Adding an observer which can be used to do on-the-fly decoding to a stream