Updated ReplicationStream contract