LOGGER.trace("Ignoring config, since rev has not changed.");
}
}
});
channels = new ConcurrentSet<DcpChannel>();
<BUG>}
public Completable connect() {</BUG>
Completable atLeastOneConfig = configProvider.configs().first().toCompletable();
return configProvider.start().concatWith(atLeastOneConfig);
}

LOGGER.trace("Ignoring config, since rev has not changed.");
}
}
});
channels = new ConcurrentSet<DcpChannel>();
}
public SessionState sessionState() {
return sessionState;
}
public Completable connect() {
Completable atLeastOneConfig = configProvider.configs().first().toCompletable();
return configProvider.start().concatWith(atLeastOneConfig);
}
