A stream that will implement the dat replication protocol