import rx.subjects.PublishSubject;
import rx.subjects.Subject;
import java.net.InetAddress;
import java.util.*;
import java.util.concurrent.TimeUnit;
<BUG>import java.util.concurrent.atomic.AtomicReference;
public class Conductor {</BUG>
private static final CouchbaseLogger LOGGER = CouchbaseLoggerFactory.getInstance(Conductor.class);
private final ConfigProvider configProvider;
private final Set<DcpChannel> channels;

import rx.subjects.PublishSubject;
import rx.subjects.Subject;
import java.net.InetAddress;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import static com.couchbase.client.dcp.util.retry.RetryBuilder.anyOf;
public class Conductor {
private static final CouchbaseLogger LOGGER = CouchbaseLoggerFactory.getInstance(Conductor.class);
private final ConfigProvider configProvider;
private final Set<DcpChannel> channels;
