class ClusterManagerBucketRefresher implements BucketRefresher {

  @Override
  public synchronized Mono<Void> register(final String name) {
    if (registrations.containsKey(name)) {
      return Mono.empty();
    }

    return Mono.defer(() -> {
      Disposable registration = registerStream(core.context(), name);
      registrations.put(name, registration);
      return Mono.empty();
    });
  }

  public  ClusterManagerBucketRefresher(final ConfigurationProvider provider, final Core core);

}