onReplicationEnd

open override fun onReplicationEnd(replicationNumber: Int)(source)

Flushes the events collected during replicationNumber and empties the buffer so the next replication starts clean.