replayandobserve stream