streaming implementation of the dat replication protocol