Implement Rx replay example