added createReplicationStream()