src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java [91:104]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for (ServerReplicationGroup entry: servers) {
            this.servers.add(new ServerConnectionInfo(this.servers.size(), entry));
        }
        this.partitionFanout = partitionFanout;
        this.networkTimeoutMillis = networkTimeoutMillis;
        this.maxTryingMillis = maxTryingMillis;
        this.serverConnectionRefresher = serverConnectionRefresher;
        this.finishUploadAck = finishUploadAck;
        this.usePooledConnection = usePooledConnection;
        this.user = user;
        this.appId = appId;
        this.appAttempt = appAttempt;
        this.shuffleWriteConfig = shuffleWriteConfig;
        this.clients = new ReplicatedWriteClient[this.servers.size()];
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java [66:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for (ServerReplicationGroup entry: servers) {
            this.servers.add(new ServerConnectionInfo(this.servers.size(), entry));
        }
        this.partitionFanout = partitionFanout;
        this.networkTimeoutMillis = networkTimeoutMillis;
        this.maxTryingMillis = maxTryingMillis;
        this.serverConnectionRefresher = serverConnectionRefresher;
        this.finishUploadAck = finishUploadAck;
        this.usePooledConnection = usePooledConnection;
        this.user = user;
        this.appId = appId;
        this.appAttempt = appAttempt;
        this.shuffleWriteConfig = shuffleWriteConfig;
        this.clients = new ReplicatedWriteClient[this.servers.size()];
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -