public static ZKClientService delegate()

in twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKClientServices.java [64:120]
46 lines of code
1 McCabe index (conditional complexity)

  public static ZKClientService delegate(final ZKClient client, ZKClientService clientService) {
    return new ForwardingZKClientService(clientService) {

      @Override
      public Long getSessionId() {
        return client.getSessionId();
      }

      @Override
      public String getConnectString() {
        return client.getConnectString();
      }

      @Override
      public Cancellable addConnectionWatcher(Watcher watcher) {
        return client.addConnectionWatcher(watcher);
      }

      public OperationFuture<String> create(String path, @Nullable byte[] data,
                                            CreateMode createMode, boolean createParent, Iterable<ACL> acl) {
        return client.create(path, data, createMode, createParent, acl);
      }

      @Override
      public OperationFuture<Stat> exists(String path, @Nullable Watcher watcher) {
        return client.exists(path, watcher);
      }

      @Override
      public OperationFuture<NodeChildren> getChildren(String path, @Nullable Watcher watcher) {
        return client.getChildren(path, watcher);
      }

      @Override
      public OperationFuture<NodeData> getData(String path, @Nullable Watcher watcher) {
        return client.getData(path, watcher);
      }

      @Override
      public OperationFuture<Stat> setData(String dataPath, byte[] data, int version) {
        return client.setData(dataPath, data, version);
      }

      @Override
      public OperationFuture<String> delete(String deletePath, int version) {
        return client.delete(deletePath, version);
      }

      public OperationFuture<ACLData> getACL(String path) {
        return client.getACL(path);
      }

      public OperationFuture<Stat> setACL(String path, Iterable<ACL> acl, int version) {
        return client.setACL(path, acl, version);
      }
    };
  }