Class ReplicationStream