Added ChannelObservable.subscribe