package meerkat.bulletinboard.workers.multiserver;

import com.google.common.util.concurrent.FutureCallback;
import meerkat.bulletinboard.SingleServerBulletinBoardClient;
import meerkat.protobuf.BulletinBoardApi.*;

import java.util.List;


/**
 * Created by Arbel Deutsch Peled on 27-Dec-15.
 */
public class MultiServerReadBatchDataWorker extends MultiServerGenericReadWorker<BulletinBoardMessage, BulletinBoardMessage> {

    public MultiServerReadBatchDataWorker(List<SingleServerBulletinBoardClient> clients,
                                          int minServers, BulletinBoardMessage payload, int maxRetry,
                                          FutureCallback<BulletinBoardMessage> futureCallback) {

        super(clients, minServers, payload, maxRetry, futureCallback);

    }

    @Override
    protected void doRead(BulletinBoardMessage payload, SingleServerBulletinBoardClient client) {
        client.readBatchData(payload, this);
    }


}
