Port `synapse.replication.tcp` to async/await.